PrepareStatement sql語句in中多個引數的實現
下邊是今天探索PrepareStatement預編譯where條件為in的sql語句的過程,在mysql環境中只有第四種方法實現了,Oracle中可能第三種也可以不過沒有測試,如果有需要可以直接跳轉。
1.通過拼接字串設定引數×
今天在實現一個數據庫批量更新的程式碼時,發現
String sql = "UPDATE t_demo SET columns='Well' WHERE column_id IN (?)";
這條語句中的引數在使用PrepareStatement來預編譯之後,是不可以傳入一個拼接字串的,比如
String criteria="'a','b','c'";
prepareStatement.setString(1,criteria);
想要達到的效果是和執行下邊一條語句一樣:
UPDATE t_demo SET columns='Well' WHERE column_id IN ('a','b','c')
但是最後發現這樣並不起作用,最後思考後恍然大悟。
因為PrepareStatement是預編譯的,所以在編譯完sql語句後發現這個sql只有一個引數,所以在設定引數的時候會預設(’a’,’b’,’c’)為一個引數,就會去查詢column_id為“’a’,’b’,’c’”的資料,結果當然是不符合期望的。
2. 通過Vector設定引數×
這個是網上找到的一個方法,我的用法如下,但是最後使用後發現也是不起作用的,但是也沒有報錯。不知道是不是我的問題。不過還是貼上來程式碼供大家研究
String arr[]={"a","b","c"};
Vector v=new Vector(Arrays.asList(arr));
prepareStatement.setObject(1,v);
prepareStatement.executeUpdate();
3. 通過PrepareStatement的setArray()方法
這個也是在網上發現的方法,這個是不支援mysql資料庫的,在mysql環境下使用會報SQLFeatureNotSupportedException異常
可能支援Oracle(沒有測試)。
程式碼如下。
String arr[]={"a" ,"b","c"};
Array v=conn.createArrayOf("VARCHAR", arr);
prepareStatement.setArray(1, v);
prepareStatement.executeUpdate();
4. 設定多個引數√
上邊幾個方法都在我的mysql環境中陣亡了之後,就只好使用笨方法了。那就是在in的條件中多加幾個“?”。
因為我這次任務處理的資料比較多達8w多條,所以我分批處理。程式碼如下:
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.Date;
public class Test {
static String url = ...;
static String user = ...;
static String password =...;
static String sql = "UPDATE t_demo SET columns='Well' WHERE column_id IN (_SQL)";
static int NUM=100;
public static void main(String[] args) throws SQLException {
// 下邊為條件,因為資料太多存在檔案中
// 讀取檔案然後通過字串的split方法轉為陣列
// TestChange是自己寫的一個讀檔案並轉為字串的類,由於不是重點所以就不上程式碼了
String content = TestChange.readString3("D:/demo.txt");
String pNo[] = content.split(",");
// 設定根據引數多少多少設定sql
setSql();
Connection conn = null;
PreparedStatement stmt=null;
try {
Class.forName("com.mysql.jdbc.Driver");
conn = DriverManager.getConnection(url, user, password);
conn.setAutoCommit(false);
stmt = conn.prepareStatement(sql);
// 分批處理陣列中的資料
for (int begin = 0; begin < pNo.length; begin += NUM) {
Date beginTime=new Date();
int end=(begin>(pNo.length-NUM)?pNo.length:(begin+NUM));
String arr[]=(String[])Arrays.copyOfRange(pNo, begin, end);
// 迴圈設定引數
int flag=1;
for (String criteria: arr) {
if(flag ==1)
System.out.print("First:"+criteria+",");
if(flag ==arr.length)
System.out.println("Last:"+criteria);
stmt.setString(flag, criteria);
flag++;
}
int num=stmt.executeUpdate();
Date endTime=new Date();
Long usedTime=endTime.getTime()-beginTime.getTime();
System.out.println("Data to be change:"+begin+"-"+end+",changed:"+num+",used time:"+usedTime);
}
conn.commit();
System.out.println("Well Done!");
} catch (Exception e) {
e.printStackTrace();
conn.rollback();
}finally{
stmt.close();
conn.close();
}
}
// 設定SQL語句,一次處理多少條資料就設定多少個“?”
private static void setSql() {
StringBuffer sb=new StringBuffer();
for(int i=0;i<NUM;++i){
sb.append("?,");
}
sb.deleteCharAt(sb.lastIndexOf(","));
sql=sql.replace("_SQL", sb.toString());
}
}
注意:上邊的程式碼僅說明了這種方法的思路和大致實現,但具有漏洞,NUM在執行到最後一批時還是會為100,但可能沒有那麼多引數需要設定。
比如我有122個數據需要update,NUM設定為100。也就是第一次設定了100個?,第二次還會繼續設定100個?,但是在setString的時候後邊的78個就會因為沒有重新set而還會是原來的那幾個,因為在我的需求中沒有影響,所以沒有處理,各位大佬們在參考的時候要注意
歡迎交流mail: [email protected]