在CSDN的JAVA基礎(chǔ)版,常常有人問(wèn)及如何得到PreparedStatement最終執(zhí)行的SQL語(yǔ)句;或者如何在控制臺(tái)輸出占位符的真實(shí)值.....
原因就是PreparedStatement執(zhí)行的sql語(yǔ)句有大量的占位符?....
問(wèn)題諸如JDBC中:
如何得到?conn.prepareStatement?最終執(zhí)行的sql語(yǔ)句。
sql="update?table1?set?a=?,b=?"
stmt?=?con.prepareStatement(sql);
stmt.setObjec?t(1,"a");
stmt.setObjec?t(2,"b");
希望可以通過(guò)stmt或者conn?得到：
update?table1?set?a='a',b='b'
亦或Hibernate中
如我執(zhí)行：find("select?*?from?t_table?where?id?=??",new?Integer(5));
在控制臺(tái)顯示SQL時(shí)只顯示：select?*?from?t_table?where?id?=??
如何才能做到將控制臺(tái)顯示的占位符用其真實(shí)的值來(lái)替換？
即控制臺(tái)輸出時(shí)顯示：select?*?from?t_table?where?id?=?5
無(wú)它，無(wú)論JDBC還是Hiberante都不提供默認(rèn)解決方案，但是參數(shù)是設(shè)置進(jìn)去的，我們?cè)谠O(shè)置的過(guò)程中可以有充分的理由來(lái)截取并獲得自己想要的東西，類似于AOP理論。
共享我在工程中的使用方法：
插入操作：
/**
?????*?執(zhí)行插入數(shù)據(jù)庫(kù)的語(yǔ)句
?????*?@param?sql
?????*?@param?params
?????*?@return?返回生成的主鍵
?????*/
????public?int?executeInsert(String?sql,?Object[]?params)?{
????????Connection?conn?=?null;
????????PreparedStatement?pstmt?=?null;
????????ResultSet?rs?=?null;
????????try?{
????????????//1?獲得連接
????????????conn?=?MyDBConnection.getInstance().getConnection();
????????????//2?設(shè)置提交方式為程序控制
????????????conn.setAutoCommit(false);
????????????//3?獲得語(yǔ)句對(duì)象
????????????pstmt?=?conn.prepareStatement(sql,?Statement.RETURN_GENERATED_KEYS);
????????????//4?設(shè)置SQL語(yǔ)句的參數(shù)
????????????if?(null?!=?params?&&?0?<?params.length)?{
????????????????setParams(pstmt,?params);
????????????}
????????????//5?打印SQL語(yǔ)句
????????????if?(MyDBConstants.showSQL)?{
????????????????getPreparedSQL(sql,?params);
????????????}
????????????//6?執(zhí)行語(yǔ)句
????????????pstmt.executeUpdate();
????????????//7?程序提交
????????????conn.commit();
????????????//8?返回生成的主鍵
????????????rs?=?pstmt.getGeneratedKeys();
????????????int?generatedKey?=?0;
????????????if?(rs.next())?{
????????????????generatedKey?=?rs.getInt(1);
????????????}
????????????if?(0?<?generatedKey)
????????????????throw?new?MySQLException("插入記錄時(shí)出錯(cuò)");
????????????return?generatedKey;
????????}?catch?(SQLException?e)?{
????????????//回滾
????????????MyDBUtil.rollBack(conn);
????????????throw?new?MySQLException(e);
????????}?finally?{
????????????//關(guān)閉打開的操作
????????????MyDBUtil.close(conn,?pstmt,?rs);
????????}
????}
更新查找操作：
/**
?????*?執(zhí)行更新或者刪除數(shù)據(jù)庫(kù)的語(yǔ)句
?????*?@param?sql
?????*?@param?params
?????*?@return?返回執(zhí)行成功與否
?????*/
????public?boolean?executeUpdateDel(String?sql,?Object[]?params)?{
????????boolean?isSuccess?=?false;
????????Connection?conn?=?null;
????????PreparedStatement?pstmt?=?null;
????????try?{
????????????//1?獲得連接
????????????conn?=?MyDBConnection.getInstance().getConnection();
????????????//2?設(shè)置提交方式為程序控制
????????????conn.setAutoCommit(false);
????????????//3?獲得語(yǔ)句對(duì)象
????????????pstmt?=?conn.prepareStatement(sql);
????????????//4?設(shè)置SQL語(yǔ)句的參數(shù)
????????????if?(null?!=?params?&&?0?<?params.length)?{
????????????????setParams(pstmt,?params);
????????????}
????????????//5?打印SQL語(yǔ)句
????????????if?(MyDBConstants.showSQL)?{
????????????????getPreparedSQL(sql,?params);
????????????}
????????????//6?執(zhí)行語(yǔ)句
????????????pstmt.executeUpdate();
????????????//7?程序提交
????????????conn.commit();
????????????//8?設(shè)置語(yǔ)句執(zhí)行的標(biāo)記
????????????isSuccess?=?true;
????????}?catch?(SQLException?e)?{
????????????//回滾
????????????MyDBUtil.rollBack(conn);
????????????throw?new?MySQLException(e);
????????}?finally?{
????????????//關(guān)閉打開的操作
????????????MyDBUtil.close(conn,?pstmt);
????????}
????????return?isSuccess;
????}
執(zhí)行查詢
?1?/**
?2??????*?執(zhí)行查詢數(shù)據(jù)庫(kù)的語(yǔ)句;
?9??????*
10??????*?@return
11??????*/
12?????public?Object?executeQuery(String?sql,?Object[]?params)?{
13?????????Connection?conn?=?null;
14?????????PreparedStatement?pstmt?=?null;
15?????????ResultSet?rs?=?null;
16?????????try?{
17?????????????//1?獲得連接
18?????????????conn?=?MyDBConnection.getInstance().getConnection();
19?????????????//2?設(shè)置提交方式為程序控制
20?????????????conn.setAutoCommit(false);
21?????????????//3?獲得語(yǔ)句對(duì)象
22?????????????pstmt?=?conn.prepareStatement(sql,?ResultSet.TYPE_SCROLL_SENSITIVE,?ResultSet.CONCUR_UPDATABLE);
23?????????????//4?設(shè)置SQL語(yǔ)句的參數(shù)
24?????????????if?(null?!=?params?&&?0?<?params.length)?{
25?????????????????setParams(pstmt,?params);
26?????????????}
27?????????????//5?打印SQL語(yǔ)句
28?????????????if?(MyDBConstants.showSQL)?{
29?????????????????getPreparedSQL(sql,?params);
30?????????????}
31?????????????//6?執(zhí)行語(yǔ)句
32?????????????rs?=?pstmt.executeQuery();
33?
34?????????????//9?程序提交
35?????????????conn.commit();
36?
37?????????????//10?獲得記錄
38?????????????Object?vo?=?new?Object();
39?????????????if?(null?!=?rs?&&?rs.next())?{
40?????????????????vo?=?rs2vo(rs);
41?????????????}
42?//????????????return?results;
43?????????????return?vo;
44?????????}?catch?(SQLException?e)?{
45?????????????//回滾
46?????????????MyDBUtil.rollBack(conn);
47?????????????throw?new?MySQLException(e);
48?????????}?finally?{
49?????????????//關(guān)閉打開的操作
50?????????????MyDBUtil.close(conn,?pstmt,?rs);
51?????????}
52?????}
看到
getPreparedSQL(sql,?params)了么？ 這個(gè)地方就是要實(shí)現(xiàn)我們預(yù)期效果的地方：
得到PrepareStatement最終執(zhí)行的sql語(yǔ)句的方法
?1?/**
?2??????*?獲得PreparedStatement向數(shù)據(jù)庫(kù)提交的SQL語(yǔ)句
?3??????*?@param?sql
?4??????*?@param?params
?5??????*?@return
?6??????*/
?7?????private?String?getPreparedSQL(String?sql,?Object[]?params)?{
?8?????????//1?如果沒(méi)有參數(shù)，說(shuō)明是不是動(dòng)態(tài)SQL語(yǔ)句
?9?????????????????int?paramNum?=?0;
10?????????????????if?(null?!=?params)??paramNum?=?params.length;
11?????????if?(1?>?paramNum)?return?sql;
12?????????//2?如果有參數(shù)，則是動(dòng)態(tài)SQL語(yǔ)句
13?????????StringBuffer?returnSQL?=?new?StringBuffer();
14?????????String[]?subSQL?=?sql.split("\\?");
15?????????for?(int?i?=?0;?i?<?paramNum;?i++)?{
16?????????????if?(params[i]?instanceof?Date)?{
17?????????????????returnSQL.append(subSQL[i]).append("?'").append(MyDateUtil.dateUtil2SQL((java.util.Date)params[i])).append("'?");
18?????????????}?else?{
19?????????????????returnSQL.append(subSQL[i]).append("?'").append(params[i]).append("'?");
20?????????????}
21?????????}
22?
23?????????if?(subSQL.length?>?params.length)?{
24?????????????returnSQL.append(subSQL[subSQL.length?-?1]);
25?????????}
26?????????return?returnSQL.toString();
27?????}
28?
29?????/**
30??????*?為PreparedStatement預(yù)編譯的SQL語(yǔ)句設(shè)置參數(shù)
31??????*?@param?pstmt
32??????*?@param?params
33??????*/
34?????private?void?setParams(PreparedStatement?pstmt,?Object[]?params)?{
35?????????????if?(null?!=?params)?{
36?????????????????for?(int?i?=?0,?paramNum?=?params.length;?i?<?paramNum;?i++)?{
37?????????????????????try?{
38?????????????????????????if?(null?!=?params[i]?&&
39?????????????????????????????params[i]?instanceof?java.util.Date)?{
40?????????????????????????????pstmt.setDate(i?+?1,?MyDateUtil.dateUtil2SQL(
41?????????????????????????????????????(java.util.Date)?params[i]));
42?????????????????????????}?else?{
43?????????????????????????????pstmt.setObject(i?+?1,?params[i]);
44?????????????????????????}
45?????????????????????}?catch?(SQLException?e)?{
46?????????????????????????throw?new?MySQLException(e);
47?????????????????????}
48?????????????????}
49?????????????}
50?????}
然后輕松核實(shí)你的控制臺(tái)或者日志文件吧......