多線程查詢資料庫
首先，你的確定數據的主鍵是否可以使用序列自增。 如果可以那麼你可以在插入數據的時候獲取序列里的值，這樣數據就不會重復了。 其次，可以創建一個公共方法，進行數據的插入操作，並且方法類型聲明為 static synchronized 類型，這樣基本上就不...
B. 如何保證多線程從mysql資料庫查詢的數據不重復
以mysql來說，可能出現臟讀、不可重復讀以及幻讀，mysql默認設置是可重復讀，即一次事務中不會讀取到不同的數據。
可以做如下操作：
1）打開兩個客戶端，均設置為RR；
2）在一個事務中，查詢某個操作查到某份數據；比如是某個欄位version=1存在數據；
3）在另一個事務中，刪除這份version=1的數據；刪除後，在2所屬的事務中查詢數據是沒有變化的，還是存在version=1的數據；
4）當我們在2所屬的事務中繼續更新數據，那麼會發現更新不了，明明我們就看到了這份version=1的數據；
緩存一致性:
緩存一致，與什麼一致？是與資料庫一致，對外查詢每個時刻一致；所以在針對於緩存與資料庫之間該先更新哪一個呢？可能有人覺得我先更新資料庫，再更新緩存不就行了嗎？但是有想過個問題嗎？
當用戶已經支付成功了，更新到資料庫，但是呢？你還在緩存中顯示未支付，在用戶點擊頻率很高並且資料庫壓力過大，來不及同步到緩存時，那你是不是很尷尬，這就是典型的不一致了。此時用戶再支付，那你又告訴他已經支付了，那他會把你罵死的
那該怎麼來做呢？我們可以這樣，先更新緩存再更新資料庫，那麼存在什麼問題呢？
1）緩存更新成功，但是資料庫更新失敗，而被其它的並發線程訪問到
2）緩存淘汰成功，但是資料庫更新失敗，這也會引發後期數據不一致
C. 如何實現多線程查詢Sqlserver庫
如何實現多線程查詢Sqlserver庫
在後台創建多個線程，訪問你對應的數據然後放在一個指定的對象裡面。 JSP上非同步不斷的發送請求向你存放數據的對象，返回數據後，放在JSP頁面裡面。
D. 多線程並發訪問資料庫中不同記錄時應該採用什麼辦法
多個線程在訪問同一個資料庫中的記錄的時候，在大並發的情況下，一定要做好事務機制。要不然後果還是很扎心的。可能遇到這樣的問題的時候首先想到的就是同步鎖機制了。
並發產生的情況
其實在實際項目開發匯總，首先要做的就是避免多個線程共用一個資料庫連接，這樣會很容易出問題，最好是一個線程一個連接。在必要的時候需要線程同步或存儲過程加鎖。如果有比較復雜的事務操作的話就需要加鎖了，如果不加的話就會出現你說的臟讀、死鎖等問題。
E. sql資料庫可以多線程查詢嗎
多線程操作，請確保每個線程操作的SQL語句中的表是相對獨立的。 不然，你需要安排線程間的順序，也就是lock代碼段。 同一時間，兩個線程一起跑同一句SQL，而且還操作同一張表，那麼，肯定就會有問題了。
一般這種是因為超出資料庫最大鏈接上限。再建立鏈接，不管緩存多少，會自動隊列消息等待。Timeout時間內沒有鏈接取消無法獲得鏈接許可權。可以將自己的資料庫鏈接個數設置大一些。
F. 如何在多線程操作資料庫
通常，最好避免鎖定 public 類型或鎖定不受應用程序控制的對象實例。例如，如果該實例可以被公開訪問，則 lock(this) 可能會有問題，因為不受控制的代碼也可能會鎖定該對象。這可能導致死鎖，即兩個或更多個線程等待釋放同一對象。出於同樣的原因，鎖定公共數據類型（相比於對象）也可能導致問題。鎖定字元串尤其危險，因為字元串被公共語言運行庫 (CLR)「暫留」。這意味著整個程序中任何給定字元串都只有一個實例，就是這同一個對象表示了所有運行的應用程序域的所有線程中的該文本。因此，只要在應用程序進程中的任何位置處具有相同內容的字元串上放置了鎖，就將鎖定應用程序中該字元串的所有實例。因此，最好鎖定不會被暫留的私有或受保護成員。某些類提供專門用於鎖定的成員。例如，Array 類型提供 SyncRoot。許多集合類型也提供 SyncRoot。
G. 怎麼在C#中用for循環創建多線程同時查詢資料庫
用SQL存儲過程，傳參。
H. java中如何用多線程訪問資料庫
//將資料庫中的數據條數分段 public void division(){ //獲取要導入的總的數據條數 String sql3="SELECT count(*) FROM [CMD].[dbo].[my1]"; 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; resie=sum%30000; }else{ resie=sum; } System.out.println(n+" "+resie); } 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].[my1]) 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.my2 values (?,?,?,?,?,?,?,?,?,?,?,?,?,?)"; try { ps=con.prepareStatement(sql2); System.out.println("-------------------------等待寫入數據條數: "+allmembers.size()); for(int i=0;i<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()); } }
I. delphi 如何用ADO進行多線程查詢資料庫
我剛做了一個在線程中使用ado的系統，實現方式如下：使用dm來存放
connection
，在各個線程中create
adoquery控制項，connection屬性設為dm中的connection，在使用完之後別忘了free。另外別忘了同步。好運！
J. 開多個線程進行sql查詢,怎麼所有的線程都查詢完成
對於復雜的業務sql查詢，可以考慮如下建議。
1.先通過sql查詢出主表信息列表list.
2.for循環list，補充查詢主表對應的子表信息。
3.在2的步驟中，可以使用多線程處理for查詢。
SQL指結構化查詢語言，SQL使我們有能力訪問資料庫，SQL是一種 ANSI 的標准計算機語言