mysql创建存储过程并通过java程序调用该存储过程_MySQL

大伟小哥_3059

大伟小哥_3059

2016-06-01

1152人浏览

原创

create table users_ning(id primary key auto_increment,pwd int); insert into users_ning values(id,1234);  insert into users_ning values(id,12345); insert into users_ning values(id,12); insert into users_ning values(id,123);  CREATE  PROCEDURE login_ning(IN p_id int,IN p_pwd int,OUT flag int)BEGINDECLARE	v_pwd int;  select pwd INTO v_pwd from users_ning  where id = p_id; if v_pwd = p_pwd then      set flag:=1;  else select v_pwd;  set flag := 0;  end if;END package demo20130528;import java.sql.*;import demo20130526.DBUtils;/** * 测试JDBC API调用过程 * @author tarena * */public class ProcedureDemo2 {  /**   * @param args * @throws Exception    */  public static void main(String[] args) throws Exception {    System.out.println(login(123, 1234));  }  /**   * 调用过程,实现登录功能   * @param id 考生id   * @param pwd 考试密码   * @return if成功:1; if密码错:0; if没有用户:-1 * @throws Exception    */  public static int login(int id, int pwd) throws Exception{    int flag = -1;    String sql = "{call login_ning(?,?,?)}";//*****    Connection conn = DBUtils.getConnMySQL();    CallableStatement stmt = null;    try{      stmt = conn.prepareCall(sql);      //传递输入参数      stmt.setInt(1, id);      stmt.setInt(2, pwd);      //注册输出参数,第三个占位符的数据类型是整型      stmt.registerOutParameter(3, Types.INTEGER);//*****      //执行过程      stmt.execute();      //获得过程执行后的输出参数      flag = stmt.getInt(3);//*****          }catch(Exception e){      e.printStackTrace();    }finally{    stmt.close();    DBUtils.dbClose();    }            return flag;  }}




package demo20130526;import java.io.File;import java.io.FileInputStream;import java.io.FileNotFoundException;import java.io.IOException;import java.sql.Connection;import java.sql.DatabaseMetaData;import java.sql.DriverManager;import java.sql.PreparedStatement;import java.sql.ResultSet;import java.sql.ResultSetMetaData;import java.sql.SQLException;import java.sql.Statement;import java.util.Properties;public class DBUtils {<span style="white-space:pre">	</span>static Connection conn = null;<span style="white-space:pre">	</span>static PreparedStatement stmt = null;<span style="white-space:pre">	</span>static ResultSet rs = null;<span style="white-space:pre">	</span>static Statement st = null;<span style="white-space:pre">	</span>static String username = null;<span style="white-space:pre">	</span>static String password = null;<span style="white-space:pre">	</span>static String url = null;<span style="white-space:pre">	</span>static String driverName = null;<span style="white-space:pre">	</span>public static Connection getConnMySQL() throws Exception {// 连接mysql 返回conn<span style="white-space:pre">		</span>getUrlUserNamePassWordClassNameMySQL();<span style="white-space:pre">		</span>conn = DriverManager.getConnection(url, username, password);<span style="white-space:pre">		</span>// conn.setAutoCommit(false);设置自动提交为false<span style="white-space:pre">		</span>return conn;<span style="white-space:pre">	</span>}<span style="white-space:pre">	</span>public static Connection getConnORCALE() throws Exception {// 连接orcale<span style="white-space:pre">																</span>// 返回conn<span style="white-space:pre">		</span>getUrlUserNamePassWordClassNameORCALE();<span style="white-space:pre">		</span>conn = DriverManager.getConnection(url, username, password);<span style="white-space:pre">		</span>// conn.setAutoCommit(false);<span style="white-space:pre">		</span>return conn;<span style="white-space:pre">	</span>}<span style="white-space:pre">	</span>private static void getUrlUserNamePassWordClassNameORCALE()<span style="white-space:pre">			</span>throws Exception {<span style="white-space:pre">		</span>// 从资源文件 获取 orcale的username password url等信息<span style="white-space:pre">		</span>Properties pro = new Properties();<span style="white-space:pre">		</span>File path = new File("src/all.properties");<span style="white-space:pre">		</span>pro.load(new FileInputStream(path));<span style="white-space:pre">		</span>String paths = pro.getProperty("filepath");<span style="white-space:pre">		</span>File file = new File(paths + "orcale.properties");<span style="white-space:pre">		</span>getFromProperties(file);<span style="white-space:pre">	</span>}<span style="white-space:pre">	</span>public static void getUrlUserNamePassWordClassNameMySQL() throws Exception {<span style="white-space:pre">		</span>// 从资源文件 获取mysql的username password url等信息<span style="white-space:pre">		</span>Properties pro = new Properties();<span style="white-space:pre">		</span>File path = new File("src/all.properties");<span style="white-space:pre">		</span>pro.load(new FileInputStream(path));<span style="white-space:pre">		</span>String paths = pro.getProperty("filepath");<span style="white-space:pre">		</span>File file = new File(paths + "mysql.properties");<span style="white-space:pre">		</span>getFromProperties(file);<span style="white-space:pre">	</span>}<span style="white-space:pre">	</span>public static void getFromProperties(File file) throws IOException,<span style="white-space:pre">			</span>FileNotFoundException, ClassNotFoundException {// 读资源文件的内容<span style="white-space:pre">		</span>Properties pro = new Properties();<span style="white-space:pre">		</span>pro.load(new FileInputStream(file));<span style="white-space:pre">		</span>username = pro.getProperty("username");<span style="white-space:pre">		</span>password = pro.getProperty("password");<span style="white-space:pre">		</span>url = pro.getProperty("url");<span style="white-space:pre">		</span>driverName = pro.getProperty("driverName");<span style="white-space:pre">		</span>Class.forName(driverName);<span style="white-space:pre">	</span>}<span style="white-space:pre">	</span>public static void dbClose() throws Exception {// 关闭所有<span style="white-space:pre">		</span>if (rs != null)<span style="white-space:pre">			</span>rs.close();<span style="white-space:pre">		</span>if (st != null)<span style="white-space:pre">			</span>st.close();<span style="white-space:pre">		</span>if (stmt != null)<span style="white-space:pre">			</span>stmt.close();<span style="white-space:pre">		</span>if (conn != null)<span style="white-space:pre">			</span>conn.close();<span style="white-space:pre">	</span>}<span style="white-space:pre">	</span>public static ResultSet getById(String tableName, int id) throws Exception {// 用id来查询结果<span style="white-space:pre">		</span>st = conn.createStatement();<span style="white-space:pre">		</span>rs = st.executeQuery("select * from " + tableName + "  where id=" + id<span style="white-space:pre">				</span>+ " ");<span style="white-space:pre">		</span>return rs;<span style="white-space:pre">	</span>}<span style="white-space:pre">	</span>public static ResultSet getByAll(String sql, Object... obj)<span style="white-space:pre">			</span>throws Exception {// 用关键字 实现查询 关键字额可以任意<span style="white-space:pre">		</span>sql = sql.replaceAll(";", "");<span style="white-space:pre">		</span>sql = sql.trim();<span style="white-space:pre">		</span>stmt = conn.prepareStatement(sql);<span style="white-space:pre">		</span>String[] strs = sql.split("//?");// 将sql 以? 非开<span style="white-space:pre">		</span>int num = strs.length;// 得到?的个数<span style="white-space:pre">		</span>int size = obj.length;<span style="white-space:pre">		</span>for (int i = 1; i 			stmt.setObject(i, obj[i - 1]);// 数组下标从0开始<span style="white-space:pre">		</span>}<span style="white-space:pre">		</span>if (size 			for (int k = size + 1; k 				stmt.setObject(k, null);// 数组下标从0开始<span style="white-space:pre">			</span>}<span style="white-space:pre">		</span>}<span style="white-space:pre">		</span>rs = stmt.executeQuery();<span style="white-space:pre">		</span>return rs;<span style="white-space:pre">	</span>}<span style="white-space:pre">	</span>public static void doInsert(String sql) throws SQLException {// 传入 sql 语句<span style="white-space:pre">																	</span>// 实现插入操作<span style="white-space:pre">		</span>st = conn.createStatement();<span style="white-space:pre">		</span>st.execute(sql);<span style="white-space:pre">	</span>}<span style="white-space:pre">	</span>public static void doInsert(String sql, Object... args) throws Exception {// 传入参数<span style="white-space:pre">																				</span>// 利用<span style="white-space:pre">																				</span>// PreparedStatement<span style="white-space:pre">																				</span>// 实现插入<span style="white-space:pre">		</span>// 传入的参数是任意多个 因为有Object 。。。args<span style="white-space:pre">		</span>int size = args.length;// 获得 Object ...obj 传过来的参数的个数<span style="white-space:pre">		</span>stmt = conn.prepareStatement(sql);<span style="white-space:pre">		</span>for (int i = 1; i 			stmt.setObject(i, args[i - 1]);// 数组下标从0开始<span style="white-space:pre">		</span>}<span style="white-space:pre">		</span>stmt.execute();<span style="white-space:pre">	</span>}<span style="white-space:pre">	</span>public static int doUpdate(String sql) throws Exception {// 传入 sql 实现更新操作<span style="white-space:pre">		</span>st = conn.createStatement();<span style="white-space:pre">		</span>int num = st.executeUpdate(sql);<span style="white-space:pre">		</span>return num;<span style="white-space:pre">	</span>}<span style="white-space:pre">	</span>public static void doUpdate(String sql, Object... obj) throws Exception {<span style="white-space:pre">		</span>// 传入参数 利用 PreparedStatement实现更新<span style="white-space:pre">		</span>// 传入的参数是任意多个 因为有Object 。。。args<span style="white-space:pre">		</span>int size = obj.length;// 获得 Object ...obj 传过来的参数的个数<span style="white-space:pre">		</span>stmt = conn.prepareStatement(sql);<span style="white-space:pre">		</span>for (int i = 1; i 			stmt.setObject(i, obj[i - 1]);// 数组下标从0开始<span style="white-space:pre">		</span>}<span style="white-space:pre">		</span>stmt.executeUpdate(sql);<span style="white-space:pre">	</span>}<span style="white-space:pre">	</span>public static boolean doDeleteById(String tableName, int id)<span style="white-space:pre">			</span>throws SQLException {// 删除记录 by id<span style="white-space:pre">		</span>st = conn.createStatement();<span style="white-space:pre">		</span>boolean b = st.execute("delete from " + tableName + " where id=" + id<span style="white-space:pre">				</span>+ "");<span style="white-space:pre">		</span>return b;<span style="white-space:pre">	</span>}<span style="white-space:pre">	</span>public static boolean doDeleteByAll(String sql, Object... args)<span style="white-space:pre">			</span>throws SQLException {// 删除记录 可以按任何关键字<span style="white-space:pre">		</span>sql = sql.replaceAll(";", "");<span style="white-space:pre">		</span>sql = sql.trim();<span style="white-space:pre">		</span>stmt = conn.prepareStatement(sql);<span style="white-space:pre">		</span>String[] strs = sql.split("//?");// 将sql 以? 非开<span style="white-space:pre">		</span>int num = strs.length;// 得到?的个数<span style="white-space:pre">		</span>int size = args.length;<span style="white-space:pre">		</span>for (int i = 1; i 			stmt.setObject(i, args[i - 1]);// 数组下标从0开始<span style="white-space:pre">		</span>}<span style="white-space:pre">		</span>if (size 			for (int k = size + 1; k 				stmt.setObject(k, null);// 数组下标从0开始<span style="white-space:pre">			</span>}<span style="white-space:pre">		</span>}<span style="white-space:pre">		</span>boolean b = stmt.execute();<span style="white-space:pre">		</span>return b;<span style="white-space:pre">	</span>}<span style="white-space:pre">	</span>public static void getMetaDate() throws Exception {// 获取数据库元素数据<span style="white-space:pre">		</span>conn = DBUtils.getConnORCALE();<span style="white-space:pre">		</span>DatabaseMetaData dmd = conn.getMetaData();<span style="white-space:pre">		</span>System.out.println(dmd.getDatabaseMajorVersion());<span style="white-space:pre">		</span>System.out.println(dmd.getDatabaseProductName());<span style="white-space:pre">		</span>System.out.println(dmd.getDatabaseProductVersion());<span style="white-space:pre">		</span>System.out.println(dmd.getDatabaseMinorVersion());<span style="white-space:pre">	</span>}<span style="white-space:pre">	</span>public static String[] getColumnNamesFromMySQL(String sql) throws Exception {<span style="white-space:pre">		</span>conn = DBUtils.getConnMySQL();<span style="white-space:pre">		</span>return getColumnName(sql);<span style="white-space:pre">	</span>}<span style="white-space:pre">	</span>public static String[] getColumnNamesFromOrcale(String sql)<span style="white-space:pre">			</span>throws Exception {<span style="white-space:pre">		</span>conn = DBUtils.getConnORCALE();<span style="white-space:pre">		</span>return getColumnName(sql);<span style="white-space:pre">	</span>}<span style="white-space:pre">	</span>private static String[] getColumnName(String sql) throws Exception {// 返回表中所有的列名<span style="white-space:pre">		</span>conn = DBUtils.getConnORCALE();<span style="white-space:pre">		</span>st = conn.createStatement();<span style="white-space:pre">		</span>rs = st.executeQuery(sql);<span style="white-space:pre">		</span>ResultSetMetaData rsmd = rs.getMetaData();<span style="white-space:pre">		</span>int num = rsmd.getColumnCount();<span style="white-space:pre">		</span>System.out.println("ColumnCount=" + num);<span style="white-space:pre">		</span>String[] strs = new String[num];<span style="white-space:pre">		</span>// 显示列名<span style="white-space:pre">		</span>for (int i = 1; i 			String str = rsmd.getColumnName(i);<span style="white-space:pre">			</span>strs[i - 1] = str;<span style="white-space:pre">			</span>System.out.print(str + "/t");<span style="white-space:pre">		</span>}<span style="white-space:pre">		</span>return strs;<span style="white-space:pre">	</span>}<span style="white-space:pre">	</span>public static void getColumnDataFromMySQL(String sql) throws Exception {// 输出表中的数据<span style="white-space:pre">		</span>conn = DBUtils.getConnMySQL();<span style="white-space:pre">		</span>getColumnData(sql);<span style="white-space:pre">	</span>}<span style="white-space:pre">	</span>public static void getColumnDataFromORCALEL(String sql) throws Exception {// 输出表中的数据<span style="white-space:pre">		</span>conn = DBUtils.getConnORCALE();<span style="white-space:pre">		</span>getColumnData(sql);<span style="white-space:pre">	</span>}<span style="white-space:pre">	</span>public static void getColumnData(String sql) throws Exception {// 输出表中的数据<span style="white-space:pre">		</span>st = conn.createStatement();<span style="white-space:pre">		</span>rs = st.executeQuery(sql);<span style="white-space:pre">		</span>ResultSetMetaData rsmd = rs.getMetaData();<span style="white-space:pre">		</span>System.out<span style="white-space:pre">				</span>.println("/n------------------------------------------------------------------------------------------------------------------------");<span style="white-space:pre">		</span>while (rs.next()) {<span style="white-space:pre">			</span>for (int i = 1; i 				System.out.print(rs.getString(i) + "/t");<span style="white-space:pre">			</span>}<span style="white-space:pre">			</span>System.out.println();<span style="white-space:pre">		</span>}<span style="white-space:pre">		</span>System.out<span style="white-space:pre">				</span>.println("------------------------------------------------------------------------------------------------------------------------");<span style="white-space:pre">	</span>}<span style="white-space:pre">	</span>public static void getTableDataFromOrcale(String sql) throws Exception {// 输出表的列名<span style="white-space:pre">																			</span>// 和表中的全部数据<span style="white-space:pre">		</span>conn = DBUtils.getConnORCALE();<span style="white-space:pre">		</span>getTableData(sql);<span style="white-space:pre">	</span>}<span style="white-space:pre">	</span>public static void getTableDataFromMysql(String sql) throws Exception {// 输出表的列名<span style="white-space:pre">																			</span>// 和表中的全部数据<span style="white-space:pre">		</span>conn = DBUtils.getConnMySQL();<span style="white-space:pre">		</span>getTableData(sql);<span style="white-space:pre">	</span>}<span style="white-space:pre">	</span>private static void getTableData(String sql) throws SQLException {<span style="white-space:pre">		</span>// getTableDataFromMysql<span style="white-space:pre">		</span>// getTableDataFromOrcale<span style="white-space:pre">		</span>st = conn.createStatement();<span style="white-space:pre">		</span>rs = st.executeQuery(sql);<span style="white-space:pre">		</span>ResultSetMetaData rsmd = rs.getMetaData();<span style="white-space:pre">		</span>int num = rsmd.getColumnCount();<span style="white-space:pre">		</span>System.out.println("ColumnCount=" + num);<span style="white-space:pre">		</span>String[] strs = new String[num];<span style="white-space:pre">		</span>// 显示列名<span style="white-space:pre">		</span>for (int i = 1; i 			String str = rsmd.getColumnName(i);<span style="white-space:pre">			</span>strs[i - 1] = str;<span style="white-space:pre">			</span>System.out.print(str + "/t");<span style="white-space:pre">		</span>}<span style="white-space:pre">		</span>System.out<span style="white-space:pre">				</span>.println("/n------------------------------------------------------------------------------------------------------------------------");<span style="white-space:pre">		</span>while (rs.next()) {<span style="white-space:pre">			</span>for (int i = 1; i 				System.out.print(rs.getString(i) + "/t");<span style="white-space:pre">			</span>}<span style="white-space:pre">			</span>System.out.println();<span style="white-space:pre">		</span>}<span style="white-space:pre">		</span>System.out<span style="white-space:pre">				</span>.println("------------------------------------------------------------------------------------------------------------------------");<span style="white-space:pre">	</span>}}

Java免费学习笔记:立即使用
解锁 Java 大师之旅:从入门到精通的终极指南

java速学教程(入门到精通)
java速学教程(入门到精通)

java怎么学习?java怎么入门?java在哪学?java怎么学才快?不用担心,这里为大家提供了java速学教程(入门到精通),有需要的小伙伴保存下载就能学习啦!

下载

相关标签:

本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

相关专题

更多
AI视频生成软件推荐
AI视频生成软件推荐

本专题汇总了当前主流的AI视频生成软件推荐与排行榜单,涵盖seko、AniShort、剧云、Lovart、LiblibAI及立刻mv等热门工具。同时整理了各软件在文生视频、图生视频、时长限制、画质表现及免费额度等方面的差异对比,助您快速选对适合创作需求的AI视频生成工具。

2026.09.16

140

9

ai生成视频的工具免费版合集
ai生成视频的工具免费版合集

本专题汇总了当前免费AI生成视频工具的排行榜与推荐清单,涵盖seko、讯飞智作、AniShort及剧云、Lovart等多模型集成平台。同时整理了各工具的免费额度、输出时长、水印政策及适用场景差异,助您快速选择合适工具开启AI视频创作。

2026.09.16

60

10

Pandas时间序列分析与可视化报表
Pandas时间序列分析与可视化报表

本专题整理Pandas日期转换、时间索引、重采样、滚动窗口、时区处理、plot绘图、Styler表格样式和报表输出方法。

2026.09.16

60

23

Pandas数据筛选索引与清洗处理
Pandas数据筛选索引与清洗处理

本专题整理Pandas中的loc、iloc、条件筛选、query查询、缺失值处理、重复值删除、类型转换和字符串列清洗方法。

2026.09.16

40

25

Pandas数据读取导入与文件导出处理
Pandas数据读取导入与文件导出处理

本专题整理Pandas读取CSV、Excel、JSON、SQL、Parquet等文件的方法,以及to_csv、to_excel、to_sql和to_parquet等常用数据导出流程。

2026.09.16

40

27

GDB怎么设置断点
GDB怎么设置断点

本专题介绍GDB按照函数名、源代码行号和文件位置设置断点的方法,详细说明run、continue、next、step等命令的配合使用,帮助定位程序崩溃、逻辑异常及代码未按预期执行的问题。

2026.09.11

360

28

GDB怎么查看变量值
GDB怎么查看变量值

本专题介绍GDB调试过程中查看变量值的具体方法,涵盖局部变量、函数参数、数组、结构体和指针内容查询,同时整理变量持续显示、格式化输出及无法读取变量时的排查思路。

2026.09.11

120

22

GDB C++程序怎么调试
GDB C++程序怎么调试

本专题围绕GDB调试C++程序的实际过程,详细说明程序编译、调试器启动、命令行参数传入、断点命中和程序继续运行等步骤,并介绍条件断点、临时断点和观察点的设置方法,方便开发者跟踪复杂代码的执行状态。

2026.09.11

120

20

Iris框架MVC架构与依赖注入合集
Iris框架MVC架构与依赖注入合集

本专题讲解Iris框架MVC开发模式,包含控制器注册、方法命名与路径映射、By参数绑定、BeforeActivation自定义路由,以及依赖注入容器注册、数据库依赖注入、返回值序列化及MVC下WebSocket与gRPC整合实践。

2026.09.11

80

15

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
热门推荐
/
最新课程
phpStudy极速入门视频教程
phpStudy极速入门视频教程

共6课时 | 54.6万人学习

独孤九贱(4)_PHP视频教程
独孤九贱(4)_PHP视频教程

共89课时 | 133万人学习