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

php中文网

php中文网

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

相关专题

更多
火山引擎API Key获取教程
火山引擎API Key获取教程

火山引擎API Key适合需要调用火山引擎云服务、AI模型、火山方舟接口或其他开放能力的开发者参考。本专题整理控制台入口、账号认证、服务开通、API Key创建、密钥复制保存、权限检查、调用测试和Key无效等常见问题排查。

2026.08.04

1

10

火山引擎API接入教程
火山引擎API接入教程

火山引擎API接入适合需要在应用、脚本、后台服务或AI工具中调用火山引擎能力的开发者参考。本专题整理控制台入口、服务开通、API Key获取、接口地址配置、请求参数填写、调用测试、权限设置、额度查询和常见接口报错排查。

2026.08.04

3

10

火山引擎DeepSeek API调用教程
火山引擎DeepSeek API调用教程

火山引擎DeepSeek API适合需要在应用、脚本、智能体或AI编程工具中调用DeepSeek模型的开发者参考。本专题整理火山引擎控制台入口、模型服务开通、API Key获取、Base URL配置、模型名称填写、调用测试、额度查询和常见接口报错排查。

2026.08.04

1

10

火山引擎控制台操作教程
火山引擎控制台操作教程

火山引擎控制台中常用功能包括API密钥管理、模型调用配置、云资源查看、账单明细、用量统计和权限分配。本专题整理控制台基础操作、服务开通流程、Key创建与保存、费用消耗查看、子账号权限设置和调用失败排查,方便开发者完成日常管理。

2026.08.04

3

10

PDF与PPT格式转换操作方法及在线转换技巧
PDF与PPT格式转换操作方法及在线转换技巧

本专题聚焦 PDF 与 PPT 文件格式转换需求,整理 PDF 转 PPT 在线转换方法、PPT 批量转换 PDF 操作步骤、转换后格式错乱处理以及文档版式检查技巧。通过详细教程帮助用户掌握 PDF、PPT 双向转换方法,解决演示文稿制作、文件整理和办公格式转换中的常见问题,提高办公效率。

2026.07.31

112

6

PDF合并文件操作方法与在线批量合并技巧
PDF合并文件操作方法与在线批量合并技巧

本专题聚焦 PDF 文件合并与文档整理需求,整理多个 PDF 合并成一个文件、图片批量转换 PDF、合同附件合并发送以及在线 PDF 合并操作方法等实用教程。通过详细步骤介绍 PDF 合并流程、文件顺序检查技巧和免费在线合并方案,帮助用户快速整理零散文档,提高办公文件处理效率。

2026.07.31

88

8

PDF转Word在线转换与文档编辑处理方法
PDF转Word在线转换与文档编辑处理方法

本专题聚焦 PDF 转 Word 文件转换与办公文档处理需求,整理 PDF 在线转换成 Word、PDF 转可编辑 Word、PDF 文件格式转换操作步骤以及转换后版式错乱、图片无法编辑等常见问题解决方法。通过详细教程帮助用户快速掌握 PDF 转 Word 技巧,提高办公文件处理效率。

2026.07.31

87

5

CodeIgniter下载教程
CodeIgniter下载教程

本合集由PHP中文网精心整理,为您提供CodeIgniter下载教程与官方正版下载安装指南。内容涵盖CI3/CI4官方获取渠道、Composer依赖安装及环境配置全流程。助您安全、高效地搭建轻量级PHP框架,轻松开启Web应用开发之旅。

2026.07.30

116

10

CodeIgniter数据库配置指南
CodeIgniter数据库配置指南

PHP中文网为您提供CodeIgniter数据库配置指南合集。本专题全面解析CI框架数据配置方法,涵盖配置文件修改、多环境连接、动态切换数据库及常见连接错误排查等实战技巧。内容详实易懂,助您轻松掌握CodeIgniter数据库配置,快速解决开发难题,提升项目构建效率。

2026.07.30

45

15

热门下载

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

精品课程

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

共6课时 | 54.4万人学习

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

共89课时 | 131.8万人学习