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

ホームページ

データベース

mysql チュートリアル

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

WBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWB

Jun 01, 2016 pm 01:08 PM

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);CREATEPROCEDURE login_ning(IN p_id int,IN p_pwd int,OUT flag int)BEGINDECLARE	v_pwd int;select pwd INTO v_pwd from users_ningwhere id = p_id; if v_pwd = p_pwd thenset 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>}}

声明

この記事の内容はネチズンが自主的に寄稿したものであり、著作権は原著者に帰属します。このサイトは、それに相当する法的責任を負いません。盗作または侵害の疑いのあるコンテンツを見つけた場合は、admin@php.cn までご連絡ください。

MySQLは、他のRDBMSと比較してどのように同時性を処理しますか？Apr 29, 2025 am 12:44 AM

mysqlhandlesconcurrencyusing amixofrow-levelandtable-levellocking、主にthroughnodb'srow-levellocking.comparedtootherrdbms、mysqlのsapproachiseformanyusecasesecasesbutmayfaceChallengeswithdeadlockdlacklikeRisikErisikErikErikErikErikErikErikErikErikErikErikErikErikErikErikeを使用してください

MySQLは、他のリレーショナルデータベースと比較してトランザクションをどのように処理しますか？Apr 29, 2025 am 12:37 AM

mysqlhandlestransactionsefectivectivelivationtivelivational supportingingacidpropertiessimilArtopostgreslesclandoracle.1）mysqluseSesrepeatable-readededededededededededefaultisolation level

MySQLで利用可能なデータ型は何ですか？Apr 29, 2025 am 12:28 AM

MySQLデータ型は、数値、日付と時刻、文字列、バイナリ、空間型に分割されます。正しいタイプを選択すると、データベースのパフォーマンスとデータストレージを最適化できます。

MySQLで効率的なSQLクエリを作成するためのベストプラクティスは何ですか？Apr 29, 2025 am 12:24 AM

ベストプラクティスには以下が含まれます。1）データ構造とMySQL処理方法の理解、2）適切なインデックス作成、3）SELECT*、4）適切な結合タイプの使用、5）サブQueriesを使用して、5）慎重に使用します。これらのプラクティスは、MySQLクエリを高速であるだけでなく、保守性、スケーラビリティ、リソース効率もすることができます。

MySQLはPostgreSQLとどのように違いますか？Apr 29, 2025 am 12:23 AM

mysqlisbetterforspeedandsimplicity、適切なforwebapplications; postgresqlexcelsincomplexdatascenararios withobustfeatures.mysqlisidealforquickprojectsandread-havytasks、whilepostgressqlessqlispreredforforivationsRedictrictiontrictdateinitegriTinitegriTiontegriTioniitaintegrategrisioniationegrisioniaty

MySQLはデータレプリケーションをどのように処理しますか？Apr 28, 2025 am 12:25 AM

MySQLは、非同期、半同期、およびグループ複製の3つのモードを介してデータの複製を処理します。 1）非同期の複製パフォーマンスは高くなりますが、データが失われる可能性があります。 2）半同期複製により、データセキュリティが向上しますが、遅延が増加します。 3）グループレプリケーションは、高可用性要件に適したマルチマスターレプリケーションとフェールオーバーをサポートします。

説明ステートメントを使用してクエリパフォーマンスを分析するにはどうすればよいですか？Apr 28, 2025 am 12:24 AM

説明ステートメントは、SQLクエリのパフォーマンスを分析および改善するために使用できます。 1.説明ステートメントを実行して、クエリプランを表示します。 2。出力結果を分析し、アクセスの種類、インデックスの使用量に注意し、順序を結合します。 3.分析結果に基づいてインデックスを作成または調整し、結合操作を最適化し、フルテーブルスキャンを回避してクエリ効率を向上させます。

MySQLデータベースをバックアップして復元するにはどうすればよいですか？Apr 28, 2025 am 12:23 AM

論理バックアップにMySQLDUMPとホットバックアップにMySQLenterPriseBackupを使用することは、MySQLデータベースをバックアップする効果的な方法です。 1. mysqldumpを使用してデータベースをバックアップします：mysqldump-uroot-pmydatabase> mydatabase_backup.sql。 2。ホットバックアップにmysqlenterprisebackupを使用：mysqlbackup - user = root-password = password - backup-dir =/path/to/backupbackup。回復するときは、対応する寿命を使用します

See all articles

ホットAIツール

Undresser.AI Undress

リアルなヌード写真を作成する AI 搭載アプリ

AI Clothes Remover

写真から衣服を削除するオンライン AI ツール。

Undress AI Tool

脱衣画像を無料で

Clothoff.io

AI衣類リムーバー

Video Face Swap

完全無料の AI 顔交換ツールを使用して、あらゆるビデオの顔を簡単に交換できます。

ホットツール

ゼンドスタジオ 13.0.1

強力な PHP 統合開発環境

EditPlus 中国語クラック版

サイズが小さく、構文の強調表示、コードプロンプト機能はサポートされていません

VSCode Windows 64 ビットのダウンロード

Microsoft によって発売された無料で強力な IDE エディター

SecLists

SecLists は、セキュリティテスターの究極の相棒です。これは、セキュリティ評価中に頻繁に使用されるさまざまな種類のリストを 1 か所にまとめたものです。 SecLists は、セキュリティテスターが必要とする可能性のあるすべてのリストを便利に提供することで、セキュリティテストをより効率的かつ生産的にするのに役立ちます。リストの種類には、ユーザー名、パスワード、URL、ファジングペイロード、機密データパターン、Web シェルなどが含まれます。テスターはこのリポジトリを新しいテストマシンにプルするだけで、必要なあらゆる種類のリストにアクセスできるようになります。