java - 从 Java 调用存储过程
问题描述
我正在尝试从我的 Java 应用程序中调用 mySQL 存储过程。当我从 mySQL 工作台调用存储过程时,它可以工作,并且我会根据我发送的参数获得正确的行数。当我尝试从 Java 调用它时,问题就来了,我没有得到任何结果,也找不到原因。我一直在关注 oracle 文档。
存储过程:
CREATE DEFINER=`root`@`localhost` PROCEDURE `comprobarUsuario`(
IN usu varchar(20),
IN pass varchar(20),
OUT idusuarios int)
BEGIN
SELECT idusuarios
FROM usuarios
WHERE usuarios.nombreUsuario = usu and usuarios.contraseña = pass;
END
我试图调用存储过程的 Java 类:
public class ConectorSQL {
public static final String URL = "jdbc:mysql://localhost:3306/ProyectoBD?autoReconnect=true&useSSL=false";
public static final String USERNAME = "root";
public static final String PASSWORD = "1627Admin";
public static Connection getConnection() {
Connection con = null;
try {
Class.forName("com.mysql.jdbc.Driver");
con = (Connection) DriverManager.getConnection(URL, USERNAME, PASSWORD);
//System.out.println("Conexion exitosa");
} catch (Exception e) {
System.out.println("Error de conexión con la base de datos");
}
return con;
}
public void mostrarDatos() {
try {
Connection con = null;
con = getConnection();
CallableStatement cs;
cs = con.prepareCall("{CALL comprobarUsuario(?,?,?)}");
cs.setString(1,"Jorge" );
cs.setString(2, "1627Jorge");
cs.registerOutParameter(3, Type.INT);
ResultSet rs2 = cs.executeQuery();
if(rs2.next()){
System.out.println(true);
}
int resultado = cs.getInt("idusuarios");
System.out.println(resultado);
con.close();
} catch (Exception e) {
}
}
}
解决方案
过程和 Java 代码几乎不需要采用。所以让我们从程序开始:
create DEFINER=`root`@`localhost` PROCEDURE `comprobarUsuario`(
IN usu varchar(20),
IN pass varchar(20),
OUT idusuarios int)
BEGIN
SELECT usuarios.idusuarios
into idusuarios
FROM usuarios
WHERE usuarios.nombreUsuario = usu and usuarios.contraseña = pass;
end
您想从数据库中检索值“idusuarios”。所以你需要把它保存在参数值中。确保 select 子句中的参数和值彼此不同,或者通过 [tablename].[column] 或别名提供列名。
Java 问题:您根本不需要 ResultSet 对象。要访问过程输出参数的值,请使用 CallableStatement 类提供的 cs.getInt()。
public void mostrarDatos(){
Connection con = null;
try {
con = getConnection();
CallableStatement cs = con.prepareCall("{CALL comprobarUsuario(?,?,?)}");
cs.setString(1, "Jorge");
cs.setString(2, "1627Jorge");
cs.registerOutParameter(3, java.sql.Types.INTEGER);
cs.executeUpdate();
int resultado = cs.getInt(3);
System.out.println(resultado);
} catch (Exception e) {
System.out.println(e);
} finally {
if(con != null) {
try {
con.close();
} catch (SQLException e) {
System.out.println(e);
}
}
}
}
推荐阅读
- python - 如何避免在我的 Python 脚本中使用路径名?
- python - Python中的自动字符串合并
- neo4j - 一台服务器/集群上的 Neo4j 多个图
- python - 如何将scrapy loader处理器用于长功能?
- ms-access - 基于索引号和其他条件的 MS Access 更新查询
- elasticsearch - ElasticSearch 根据字段值的计数提高相关性
- android - 有错误的基本 android studio 项目
- intellij-idea - Kotlin println 特殊字符
- java - 休眠。延迟加载。最佳实践。怎么了?
- python - Django 错误“包含的 URLconf 中似乎没有任何模式”