?在項(xiàng)目中，可能會(huì)遇到sybase 移植到 mysql的情況，因?yàn)閟ybase 支持存儲(chǔ)過(guò)程的可變參數(shù)，而mysql不能支持，所以，在調(diào)用mysql的時(shí)候，需要感知存儲(chǔ)過(guò)程到底有幾個(gè)參數(shù)，來(lái)合理的配置參數(shù)數(shù)量：
如下是代碼
package com.xxx.util;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.Hashtable;
import java.util.Map;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
public class ProcedureHelper {
/*是否是開(kāi)發(fā)模式*/
static boolean DEV = false;
static Map<String,Integer> CACHE = new Hashtable<String,Integer>(100);
static Pattern PATTERN_ARGS = Pattern.compile("`\\s*\\((.*)\\)\\s*begin",Pattern.DOTALL|Pattern.CASE_INSENSITIVE);
static Pattern PATTERN_ARG = Pattern.compile("(in|out|inout)[^-,]*(,|$)",Pattern.DOTALL|Pattern.CASE_INSENSITIVE);
private static int doWork(Connection con,String proc) throws Exception {
Statement stmt = null;
stmt = con.createStatement(); //3、Statement 接口需要通過(guò)Connection 接口進(jìn)行實(shí)例化操作
ResultSet rs = stmt.executeQuery("show create procedure "+proc);
if(rs.next()){
//第三列為 存儲(chǔ)過(guò)程的代碼
String code = rs.getString(3);
Matcher m = PATTERN_ARGS.matcher(code);
if(m.find()){
String args = m.group(1);
if(args.matches("\\s*"))
return 0;
else{
Matcher m2 = PATTERN_ARG.matcher(args);
int num = 0;
while(m2.find()){
//System.out.println(m2.group());
num++;
}
return num;
}
}else{
throw new RuntimeException("存儲(chǔ)過(guò)程: "+proc+"無(wú)法通過(guò)正則表達(dá)式獲取參數(shù)個(gè)數(shù):\n"+code);
}
}
rs.close();
stmt.close();
throw new RuntimeException("沒(méi)有該存儲(chǔ)過(guò)程");
}
/**
* 注意， 在存儲(chǔ)過(guò)程的參數(shù)中，不能寫(xiě)注釋，特別是 in xxx, 格式的注釋,不然會(huì)被錯(cuò)誤的識(shí)別
* @param con JDBC連接, 且不在函數(shù)內(nèi)釋放資源
* @param proc 調(diào)用的存儲(chǔ)過(guò)程
* @param args 傳遞給存儲(chǔ)過(guò)程的參數(shù)
* @throws 解析失敗
* */
public static int getProcedureArgsNumber(Connection con,String proc) throws Exception {
if(con == null || proc == null|| proc.equals("")){
throw new RuntimeException("proc, con 參數(shù)不能為空");
}
//這里可以做緩存
return doWork(con,proc);
}
public static void main(String arg[]) throws Exception{
Connection con = null; //表示數(shù)據(jù)庫(kù)的連接對(duì)象
Class.forName("com.mysql.jdbc.Driver"); //1、使用CLASS 類加載驅(qū)動(dòng)程序
con = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/test?useUnicode=true&characterEncoding=UTF-8","root","root"); //2、連接數(shù)據(jù)庫(kù)
System.out.println(getProcedureArgsNumber(con,"my_procedure"));
con.close();
}
}
該代碼對(duì)存儲(chǔ)過(guò)程的感知，是利用正則表達(dá)式的，所以在匹配的時(shí)候，可能遇到一些極端的情況，如 注釋中包含了符合規(guī)則的 語(yǔ)句，不過(guò)一般來(lái)說(shuō)，這種情況極少發(fā)生。
更多文章、技術(shù)交流、商務(wù)合作、聯(lián)系博主
微信掃碼或搜索：z360901061
微信掃一掃加我為好友
QQ號(hào)聯(lián)系： 360901061
您的支持是博主寫(xiě)作最大的動(dòng)力，如果您喜歡我的文章，感覺(jué)我的文章對(duì)您有幫助，請(qǐng)用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧，狠狠點(diǎn)擊下面給點(diǎn)支持吧，站長(zhǎng)非常感激您！手機(jī)微信長(zhǎng)按不能支付解決辦法：請(qǐng)將微信支付二維碼保存到相冊(cè)，切換到微信，然后點(diǎn)擊微信右上角掃一掃功能，選擇支付二維碼完成支付。
【本文對(duì)您有幫助就好】元
