c#编程中，怎样使用多线程处理数据库读取的信息

//你分给5个线程 他也不是同时出来的,多线程还是要等CPU闲下来才能工作的。。。。

//非要这样做 参考如下 给你举个例子 取第二条记录。

Thread threadGetTop2=new Thead(new ThreadStart(GetTop2))

threadGetTop2.Start()

private void GetTop2()

{

//这里用ADO.NET打开连接

string sql="select top 1 * from (select top 2* from A order by id desc)t"

//拿到记录

}

启动2个线程

一个用来插入数据

另一个要监视，监视线程可以考虑这么来实现 ：每隔一段时间来对数据库进行检索，获得更新的部分数据，可以通过SQL语言实现。

当然这个办法比较笨

效率不好

如果你对数据库足够了解

应当知道里面有触发器机制

对插入数据建立一个触发器

每次的数据插入就会引发一个触发器事件

这时候再来对数据库中的数据进行检索

或者你可以自定义一个监听器 Listener

对数据进行监听

//将数据库中的数据条数分段 public void division(){ //获取要导入的总的数据条数 String sql3="SELECT count(*) FROM [CMD].[dbo].[mycopy1]" try { pss=cons.prepareStatement(sql3) rss=pss.executeQuery() while(rss.next()){ System.out.println("总记录条数:"+rss.getInt(1)) sum=rss.getInt(1) } //每30000条记录作为一个分割点 if(sum>=30000){n=sum/30000 residue=sum%30000 }else{residue=sum } System.out.println(n+" "+residue) } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace() }}线程类public MyThread(int start,int end) { this.end=end this.start=start System.out.println("处理掉余数") try { System.out.println("--------"+Thread.currentThread().getName()+"------------") Class.forName(SQLSERVERDRIVER) System.out.println("加载sqlserver驱动...") cons = DriverManager.getConnection(CONTENTS,UNS,UPS) stas = cons.createStatement() System.out.println("连接SQLServer数据库成功！！")System.out.println("加载mysql驱动.....") Class.forName(MYSQLDRIVER) con = DriverManager.getConnection(CONTENT,UN,UP) sta = con.createStatement() // 关闭事务自动提交con.setAutoCommit(false) System.out.println("连接mysql数据库成功！！") } catch (Exception e) {e.printStackTrace() } // TODO Auto-generated constructor stub } public ArrayList<Member>getAll(){ Member member String sql1="select * from (select row_number() over (order by pmcode) as rowNum,*" +" from [CMD].[dbo].[mycopy1]) as t where rowNum between "+start+" and "+end try { System.out.println("正在获取数据...") allmembers=new ArrayList() rss=stas.executeQuery(sql1) while(rss.next()){member=new Member() member.setAddress1(rss.getString("address1")) member.setBnpoints(rss.getString("bnpoints")) member.setDbno(rss.getString("dbno")) member.setExpiry(rss.getString("expiry")) member.setHispoints(rss.getString("hispoints")) member.setKypoints(rss.getString("kypoints")) member.setLevels(rss.getString("levels")) member.setNames(rss.getString("names")) member.setPmcode(rss.getString("pmcode")) member.setRemark(rss.getString("remark")) member.setSex(rss.getString("sex")) member.setTelephone(rss.getString("telephone")) member.setWxno(rss.getString("wxno")) member.setPmdate(rss.getString("pmdate")) allmembers.add(member) // System.out.println(member.getNames()) } System.out.println("成功获取sqlserver数据库数据！") return allmembers } catch (SQLException e) { // TODO Auto-generated catch block System.out.println("获取sqlserver数据库数据发送异常！") e.printStackTrace() } try { rss.close() stas.close() } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace() } return null} public void inputAll(ArrayList<Member>allmembers){ System.out.println("开始向mysql中写入") String sql2="insert into test.mycopy2 values (?,?,?,?,?,?,?,?,?,?,?,?,?,?)" try { ps=con.prepareStatement(sql2) System.out.println("-------------------------等待写入数据条数: "+allmembers.size()) for(int i=0i<allmembers.size()i++){ps.setString(1, allmembers.get(i).getPmcode()) ps.setString(2, allmembers.get(i).getNames()) //System.out.println(allmembers.get(i).getNames()) ps.setString(3, allmembers.get(i).getSex()) ps.setString(4, allmembers.get(i).getTelephone()) ps.setString(5, allmembers.get(i).getAddress1()) ps.setString(6, allmembers.get(i).getPmdate()) ps.setString(7, allmembers.get(i).getExpiry()) ps.setString(8, allmembers.get(i).getLevels()) ps.setString(9, allmembers.get(i).getDbno()) ps.setString(10, allmembers.get(i).getHispoints()) ps.setString(11, allmembers.get(i).getBnpoints()) ps.setString(12, allmembers.get(i).getKypoints()) ps.setString(13, allmembers.get(i).getWxno()) ps.setString(14, allmembers.get(i).getRemark()) //插入命令列表//ps.addBatch() ps.executeUpdate() } //ps.executeBatch() con.commit() ps.close() con.close() this.flag=false System.out.println(Thread.currentThread().getName()+"--->OK") } catch (SQLException e) { // TODO Auto-generated catch block System.out.println("向mysql中更新数据时发生异常！") e.printStackTrace() } } @Override public void run() { // TODO Auto-generated method stub while(true&&flag){ this.inputAll(getAll()) } }

---