浙江网站优化公司怎么自己弄一个平台
目录
- 前言
- 1. 基本知识
- 2. Demo
- 3. 实战
前言
🤟 找工作,来万码优才:👉 #小程序://万码优才/r6rqmzDaXpYkJZF
爬虫神器,无代码爬取,就来:bright.cn
Java基本知识:
- java框架 零基础从入门到精通的学习路线 附开源项目面经等(超全)
- 【Java项目】实战CRUD的功能整理(持续更新)
1. 基本知识
Java 通过 JDBC 连接 Oracle 数据库并调用存储过程的方式主要有两种:
-
使用 CallableStatement 直接调用存储过程(原生 JDBC)
-
使用 MyBatis 映射存储过程(推荐)
再补充个Sql的基本知识:(sql 参数检查)
查询对应存储过程的输入输出是什么:
SELECT argument_name, data_type, in_out
FROM all_arguments
WHERE object_name = 'xxx'
AND owner = 'YOUR_SCHEMA_NAME';
然后确保 jdbcType 与数据库的参数类型一致,比如:
- VARCHAR2 → jdbcType=VARCHAR
- NUMBER → jdbcType=NUMERIC
- DATE → jdbcType=TIMESTAMP 或 jdbcType=DATE
截图如下:
2. Demo
需要先引入依赖包,否则会出现如下所示:
java.lang.ClassNotFoundException: oracle.jdbc.driver.OracleDriverat java.net.URLClassLoader.findClass(URLClassLoader.java:382)
截图如下:
依赖包如下:
<!-- oracle-->
<dependency><groupId>com.oracle.database.jdbc</groupId><artifactId>ojdbc8</artifactId><version>19.8.0.0</version>
</dependency>
不以Mybatis进行解析,纯Demo:
-
加载 Oracle JDBC 驱动:
使用 oracle.jdbc.driver.OracleDriver 进行驱动加载(Spring Boot 可通过 DataSource 自动管理) -
建立数据库连接:
通过DriverManager.getConnection()
或数据源 DataSource 连接数据库 -
创建 CallableStatement:
通过connection.prepareCall("{ call procedure_name(?, ?, ...) }")
创建存储过程调用对象 -
绑定输入、输出参数:
IN 参数:使用setXXX(index, value)
绑定值
OUT 参数:使用registerOutParameter(index, sqlType)
声明输出参数 -
执行存储过程:
使用callableStatement.execute()
执行存储过程
通过getXXX(index)
读取输出参数的返回值 -
关闭连接:
CallableStatement 和 Connection 需要在 finally 块中关闭,避免资源泄露
import java.sql.*;
import java.text.SimpleDateFormat;public class OracleProcedureCall {public static void main(String[] args) {String url = "jdbc:oracle:thin:@(DESCRIPTION =(ADDRESS_LIST=(ADDRESS=(PROTOCOL=TCP)(HOST=xxxxx)(PORT=1521)))(CONNECT_DATA=(SERVICE_NAME=xxxx)))";String username = "xxx";String password = "xxx";Connection conn = null;CallableStatement cstmt = null;try {// 1. 加载驱动(JDBC 4.0 及以上可省略)Class.forName("oracle.jdbc.driver.OracleDriver");// 2. 建立数据库连接conn = DriverManager.getConnection(url, username, password);// 3. 预编译存储过程,使用命名参数String procedureCall = "{ call xxxxxx(?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?) }";cstmt = conn.prepareCall(procedureCall);// 4. 设置输入参数cstmt.setString("xx1", "1");cstmt.setInt("xx2", 2);// 处理日期时间String dateStr = "2025-03-12 04:31:11"; // 格式:yyyy-MM-dd HH:mm:ssSimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");java.util.Date parsedDate = dateFormat.parse(dateStr);Timestamp timestamp = new Timestamp(parsedDate.getTime());cstmt.setTimestamp("xx3", timestamp);cstmt.setString("xx4", "4");cstmt.setString("xx5", "5");cstmt.setString("xx6", "6");cstmt.setString("xx7", "7");// 5. 注册输出参数cstmt.registerOutParameter("wl_cntr_plac", Types.VARCHAR);cstmt.registerOutParameter("wl_new_cntr", Types.VARCHAR);cstmt.registerOutParameter("wl_new_cntr_plac", Types.VARCHAR);cstmt.registerOutParameter("wl_return", Types.VARCHAR);// 6. 执行存储过程cstmt.execute();// 7. 获取输出参数String wl_cntr_plac = cstmt.getString("wl_cntr_plac");String wl_new_cntr = cstmt.getString("wl_new_cntr");String wl_new_cntr_plac = cstmt.getString("wl_new_cntr_plac");String wl_return = cstmt.getString("wl_return");System.out.println("wl_cntr_plac: " + wl_cntr_plac);System.out.println("wl_new_cntr: " + wl_new_cntr);System.out.println("wl_new_cntr_plac: " + wl_new_cntr_plac);System.out.println("wl_return: " + wl_return);} catch (Exception e) {e.printStackTrace();} finally {// 8. 关闭资源try {if (cstmt != null) cstmt.close();if (conn != null) conn.close();} catch (SQLException e) {e.printStackTrace();}}}
}
截图如下:
如果是Mybaits写法,具体如下:
特意隐藏一些数据,以xx进行代替:
<insert id="callExchangeCntrGateProcedure" statementType="CALLABLE">{ call xxx(#{xx1,mode=IN,jdbcType=VARCHAR},#{xx2,mode=IN,jdbcType=NUMERIC},#{xx3,mode=IN,jdbcType=DATE},#{xx4,mode=IN,jdbcType=VARCHAR},#{xx5,mode=IN,jdbcType=VARCHAR},#{xx6,mode=IN,jdbcType=VARCHAR},#{xx8,mode=OUT,jdbcType=VARCHAR},#{xx7,mode=OUT,jdbcType=VARCHAR},#{xx9,mode=OUT,jdbcType=VARCHAR},#{xx10,mode=IN,jdbcType=VARCHAR},#{xx11,mode=OUT,jdbcType=VARCHAR}) }
</insert>
然后在 Mapper 接口 里这样写:
@Mapper
public interface MyMapper {void callExchangeCntrGateProcedure(Map<String, Object> params);
}
调用时:
@Autowired
private MyMapper myMapper;public void executeProcedure() {Map<String, Object> params = new HashMap<>();params.put("xx1", "E3051486");params.put("xx2", 1001);params.put("xx3", new Timestamp(System.currentTimeMillis()));params.put("xx4", "SLS");params.put("xx5", "R");params.put("xx6", "G05");params.put("xx7", "C1");// MyBatis 会自动填充 OUT 参数myMapper.callExchangeCntrGateProcedure(params);System.out.println("wl_cntr_plac: " + params.get("wl_cntr_plac"));System.out.println("wl_new_cntr: " + params.get("wl_new_cntr"));System.out.println("wl_new_cntr_plac: " + params.get("wl_new_cntr_plac"));System.out.println("wl_return: " + params.get("wl_return"));
}
方法 | 适用场景 | 主要特点 |
---|---|---|
CallableStatement(命名参数) | 适用于 JDBC 原生代码 | 手动绑定参数,清晰易维护 |
MyBatis #{} 方式 | 适用于 Spring + MyBatis | 代码更简洁,自动管理参数 |
3. 实战
以Demo为基本知识 融合到实战中!
本身需要跨源数据库,所以结合DS注解,该注解可看我之前的文章:详细分析MybatisPLus中@DS切换数据源的基本知识(附Demo)
新建一个基本类,用于跨源数据库
对应实现类打上DS:
实际代码如下:
@Resource
private CabinetSwapMapper cabinetSwapMapper;@Override
@DS("xxx")
public Map<String, Object> callExchangeCntrGate(CabinetSwapDO cabinetSwapDO, String cntrDam) {// **调用存储过程**Map<String, Object> params = new HashMap<>();params.put("xxx", cabinetSwapDO.getOrderId());// 省略params.put("wlChangRsn", cabinetSwapDO.getDamDes());// 执行存储过程cabinetSwapMapper.callExchangeCntrGate(params);return params;
}
此处的存储过程后续便于对接Mabatis.xml文件:
@Mapper
public interface CabinetSwapMapper extends BaseMapperX<CabinetSwapDO> {void callExchangeCntrGate(Map<String, Object> params);
}
注意的关键点如下:
后续直接调用即可:
Map<String, Object> result = commonGateService.callExchangeCntrGate(cabinetSwapDO, reason);
String xxx= (String) result.get("xxx");
上述代码需要注意IN有什么要传入的,而且参数的字段类型要正确,传输的格式也要正确!
可以先在数据库软件中测试对应的类型: