Sql Server的存储过程与Java代码相连接调用(一)

时间:2021-06-11 04:25:02

           我所写的项目是使用Maven开发,在pom.xml中添加如下必要依赖:

          添加com.microsoft.sqlserver的mssql-jdbc 6.2.1.jre8的依赖

	<dependency>
<groupId>com.microsoft.sqlserver</groupId>
<artifactId>mssql-jdbc</artifactId>
<version>6.2.1.jre8</version>
</dependency>


           Java后台代码如下代码块所示。其中,代码中所调用的 proc_test02存储过程,可参考我写的博客: SQL Server数据库学习之 —— 存储过程- 事务 - try-catch代码块

           我所写的代码有些简化,以“学生 -- 班级 -- 教师”这种经典模式来讲解自己所运用的知识点。可能网友直接将我的代码粘贴-复制,运行会报错。不过其中的知识点确是无误的!


package org.com.api.service;

import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;
import java.util.Map;

import com.microsoft.sqlserver.jdbc.SQLServerCallableStatement;
import com.microsoft.sqlserver.jdbc.SQLServerDataTable;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.dao.DataAccessException;
import org.springframework.jdbc.core.CallableStatementCallback;
import org.springframework.jdbc.core.CallableStatementCreator;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Service;

@Service
public class ClazzService {

@Autowired
private JdbcTemplate jdbcTemplate;

@Autowired
@Qualifier("sqlServerJdbcTemplate")
private JdbcTemplate sqlServerJdbcTemplate;


/**
* 新增学生
* @return
*/
public int addStudent(Student student) {

Integer testCount = 0;

Integer count = jdbcTemplate.execute(new CallableStatementCreator() {

@Override
public CallableStatement createCallableStatement(Connection con) throws SQLException {
// proc_test02(?,?,?,?,?)中的问号,代表调用的存储过程“proc_test02”中的参数
CallableStatement cs = con.prepareCall("{call proc_test02(?,?,?,?,?)}");

// 为CallableStatement设置参数
cs.setString(1, student.getSex()); // 获取性别,sex字段为String类型
cs.setString(2, student.getName()); // 获取姓名,name字段为String类型
cs.setInt(3, student.getAge()); // 获取年龄,age字段为int类型
cs.setInt(4, student.getStuNo()); // 获取学号,stuNo字段为int类型
cs.registerOutParameter(5, java.sql.Types.INTEGER); // =1, 则正确!

return cs;
}
}, new CallableStatementCallback<Integer>() {

@Override
public Integer doInCallableStatement(CallableStatement cs) throws SQLException, DataAccessException {
cs.execute();
return cs.getInt(5);
}
});

testCount = count;

return testCount; // = 1
}


}