Spring JdbcTemplate方法詳解

時間 2019-11-07

標籤 spring jdbctemplate 方法詳解欄目 Spring 简体版

原文原文鏈接

其中CREATE FUNCTION FUNCTION_TEST用於建立自定義函數，CREATE PROCEDURE PROCEDURE_TEST用於建立存儲過程，注意這些建立語句是數據庫相關的，本示例中的語句只適用於HSQLDB數據庫。 java

其次修改JdbcTemplateTest的tearDown方法，修改後以下所示： mysql

java代碼：

Java代碼

其中drop語句用於刪除建立的存儲過程、自定義函數及數據庫表。 sql

接下來看一下hsqldb如何調用自定義函數：數據庫

java代碼：

Java代碼

@Test
public void testCallableStatementCreator1() {
final String callFunctionSql = "{call FUNCTION_TEST(?)}";
List<SqlParameter> params = new ArrayList<SqlParameter>();
params.add(new SqlParameter(Types.VARCHAR));
params.add(new SqlReturnResultSet("result",
new ResultSetExtractor<Integer>() {
@Override
public Integer extractData(ResultSet rs) throws SQLException,
DataAccessException {
while(rs.next()) {
return rs.getInt(1);
}
return 0;
}));
Map<String, Object> outValues = jdbcTemplate.call(
new CallableStatementCreator() {
@Override
public CallableStatement createCallableStatement(Connection conn) throws SQLException {
CallableStatement cstmt = conn.prepareCall(callFunctionSql);
cstmt.setString(1, "test");
return cstmt;
}}, params);
Assert.assertEquals(4, outValues.get("result"));
}

{call FUNCTION_TEST(?)}：定義自定義函數的sql語句，注意hsqldb {?= call …}和{call …}含義是同樣的，而好比mysql中兩種含義是不同的；
params：用於描述自定義函數佔位符參數或命名參數類型；SqlParameter用於描述IN類型參數、SqlOutParameter用於描述OUT類型參數、SqlInOutParameter用於描述INOUT類型參數、SqlReturnResultSet用於描述調用存儲過程或自定義函數返回的ResultSet類型數據，其中SqlReturnResultSet須要提供結果集處理回調用於將結果集轉換爲相應的形式，hsqldb自定義函數返回值是ResultSet類型。
CallableStatementCreator：提供Connection對象用於建立CallableStatement對象
outValues：調用call方法將返回類型爲Map<String, Object>對象；
outValues.get("result")：獲取結果，即經過SqlReturnResultSet對象轉換過的數據；其中SqlOutParameter、SqlInOutParameter、SqlReturnResultSet指定的name用於從call執行後返回的Map中獲取相應的結果，即name是Map的鍵。

注：由於hsqldb {?= call …}和{call …}含義是同樣的，所以調用自定義函數將返回一個包含結果的ResultSet。 ide

最後讓咱們示例下mysql如何調用自定義函數：函數

java代碼：

Java代碼

@Test
public void testCallableStatementCreator2() {
JdbcTemplate mysqlJdbcTemplate = new JdbcTemplate(getMysqlDataSource);
//2.建立自定義函數
String createFunctionSql =
"CREATE FUNCTION FUNCTION_TEST(str VARCHAR(100)) " +
"returns INT return LENGTH(str)";
String dropFunctionSql = "DROP FUNCTION IF EXISTS FUNCTION_TEST";
mysqlJdbcTemplate.update(dropFunctionSql);
mysqlJdbcTemplate.update(createFunctionSql);
//3.準備sql,mysql支持{?= call …}
final String callFunctionSql = "{?= call FUNCTION_TEST(?)}";
//4.定義參數
List<SqlParameter> params = new ArrayList<SqlParameter>();
params.add(new SqlOutParameter("result", Types.INTEGER));
params.add(new SqlParameter("str", Types.VARCHAR));
Map<String, Object> outValues = mysqlJdbcTemplate.call(
new CallableStatementCreator() {
@Override
public CallableStatement createCallableStatement(Connection conn) throws SQLException {
CallableStatement cstmt = conn.prepareCall(callFunctionSql);
cstmt.registerOutParameter(1, Types.INTEGER);
cstmt.setString(2, "test");
return cstmt;
}}, params);
Assert.assertEquals(4, outValues.get("result"));
}
public DataSource getMysqlDataSource() {
String url = "jdbc:mysql://localhost:3306/test";
DriverManagerDataSource dataSource =
new DriverManagerDataSource(url, "root", ""); dataSource.setDriverClassName("com.mysql.jdbc.Driver");
return dataSource;
}

getMysqlDataSource：首先啓動mysql（本書使用5.4.3版本），其次登陸mysql建立test數據庫（「create database test;」），在進行測試前，請先下載並添加mysql-connector-java-5.1.10.jar到classpath；
{?= call FUNCTION_TEST(?)}：能夠使用{?= call …}形式調用自定義函數；
params：無需使用SqlReturnResultSet提取結果集數據，而是使用SqlOutParameter來描述自定義函數返回值；
CallableStatementCreator：同上個例子含義同樣；
cstmt.registerOutParameter(1, Types.INTEGER)：將OUT類型參數註冊爲JDBC類型Types.INTEGER，此處即返回值類型爲Types.INTEGER。
outValues.get("result")：獲取結果，直接返回Integer類型，比hsqldb簡單多了吧。

最後看一下如何如何調用存儲過程：測試

java代碼：

Java代碼

@Test
public void testCallableStatementCreator3() {
final String callProcedureSql = "{call PROCEDURE_TEST(?, ?)}";
List<SqlParameter> params = new ArrayList<SqlParameter>();
params.add(new SqlInOutParameter("inOutName", Types.VARCHAR));
params.add(new SqlOutParameter("outId", Types.INTEGER));
Map<String, Object> outValues = jdbcTemplate.call(
new CallableStatementCreator() {
@Override
public CallableStatement createCallableStatement(Connection conn) throws SQLException {
CallableStatement cstmt = conn.prepareCall(callProcedureSql);
cstmt.registerOutParameter(1, Types.VARCHAR);
cstmt.registerOutParameter(2, Types.INTEGER);
cstmt.setString(1, "test");
return cstmt;
}}, params);
Assert.assertEquals("Hello,test", outValues.get("inOutName"));
Assert.assertEquals(0, outValues.get("outId"));
}