mysql創造存儲過程并通過java程序調用該存儲過程

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)
BEGIN
DECLARE	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);
 //注冊

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 {
	static Connection conn = null;
	static PreparedStatement stmt = null;
	static ResultSet rs = null;
	static Statement st = null;
	static String username = null;
	static String password = null;
	static String url = null;
	static String driverName = null;


	public static Connection getConnMySQL() throws Exception {// 連接mysql 返回conn
	getUrlUserNamePassWordClassNameMySQL();
	conn = DriverManager.getConnection(url, username, password);
	// conn.setAutoCommit(false);設置自動提交為false
	return conn;
	}


	public static Connection getConnORCALE() throws Exception {// 連接orcale
	// 返回conn
	getUrlUserNamePassWordClassNameORCALE();
	conn = DriverManager.getConnection(url, username, password);
	// conn.setAutoCommit(false);
	return conn;
	}


	private static void getUrlUserNamePassWordClassNameORCALE()
	throws Exception {
	// 從資源文件 獲取 orcale的username password url等信息
	Properties pro = new Properties();
	File path = new File("src/all.properties");
	pro.load(new FileInputStream(path));
	String paths = pro.getProperty("filepath");
	File file = new File(paths + "orcale.properties");
	getFromProperties(file);


	}


	public static void getUrlUserNamePassWordClassNameMySQL() throws Exception {
	// 從資源文件 獲取mysql的username password url等信息
	Properties pro = new Properties();
	File path = new File("src/all.properties");
	pro.load(new FileInputStream(path));
	String paths = pro.getProperty("filepath");
	File file = new File(paths + "mysql.properties");
	getFromProperties(file);
	}


	public static void getFromProperties(File file) throws IOException,
	FileNotFoundException, ClassNotFoundException {// 讀資源文件的內容
	Properties pro = new Properties();
	pro.load(new FileInputStream(file));
	username = pro.getProperty("username");
	password = pro.getProperty("password");
	url = pro.getProperty("url");
	driverName = pro.getProperty("driverName");
	Class.forName(driverName);
	}


	public static void dbClose() throws Exception {// 關閉所有
	if (rs != null)
	rs.close();
	if (st != null)
	st.close();
	if (stmt != null)
	stmt.close();
	if (conn != null)
	conn.close();
	}


	public static ResultSet getById(String tableName, int id) throws Exception {// 用id來查詢結果
	st = conn.createStatement();
	rs = st.executeQuery("select * from " + tableName + "  where id=" + id
	+ " ");
	return rs;
	}


	public static ResultSet getByAll(String sql, Object... obj)
	throws Exception {// 用關鍵字 實現查詢 關鍵字額可以任意
	sql = sql.replaceAll(";", "");
	sql = sql.trim();
	stmt = conn.prepareStatement(sql);
	String[] strs = sql.split("\\?");// 將sql 以? 非開
	int num = strs.length;// 得到?的個數
	int size = obj.length;
	for (int i = 1; i <= size; i++) {
	stmt.setObject(i, obj[i - 1]);// 數組下標從0開始
	}
	if (size < num) {
	for (int k = size + 1; k <= num; k++) {
	stmt.setObject(k, null);// 數組下標從0開始
	}
	}
	rs = stmt.executeQuery();
	return rs;
	}


	public static void doInsert(String sql) throws SQLException {// 傳入 sql 語句
	// 實現插入操作
	st = conn.createStatement();
	st.execute(sql);
	}


	public static void doInsert(String sql, Object... args) throws Exception {// 傳入參數
	// 利用
	// PreparedStatement
	// 實現插入
	// 傳入的參數是任意多個 因為有Object 。。args
	int size = args.length;// 獲得 Object ...obj 傳過來的參數的個數
	stmt = conn.prepareStatement(sql);
	for (int i = 1; i <= size; i++) {
	stmt.setObject(i, args[i - 1]);// 數組下標從0開始
	}
	stmt.execute();
	}


	public static int doUpdate(String sql) throws Exception {// 傳入 sql 實現更新操作
	st = conn.createStatement();
	int num = st.executeUpdate(sql);
	return num;
	}


	public static void doUpdate(String sql, Object... obj) throws Exception {
	// 傳入參數 利用 PreparedStatement實現更新
	// 傳入的參數是任意多個 因為有Object 。。args
	int size = obj.length;// 獲得 Object ...obj 傳過來的參數的個數
	stmt = conn.prepareStatement(sql);
	for (int i = 1; i <= size; i++) {
	stmt.setObject(i, obj[i - 1]);// 數組下標從0開始
	}
	stmt.executeUpdate(sql);
	}


	public static boolean doDeleteById(String tableName, int id)
	throws SQLException {// 刪除記錄 by id
	st = conn.createStatement();
	boolean b = st.execute("delete from " + tableName + " where id=" + id
	+ "");
	return b;
	}


	public static boolean doDeleteByAll(String sql, Object... args)
	throws SQLException {// 刪除記錄 可以按任何關鍵字
	sql = sql.replaceAll(";", "");
	sql = sql.trim();
	stmt = conn.prepareStatement(sql);
	String[] strs = sql.split("\\?");// 將sql 以? 非開
	int num = strs.length;// 得到?的個數
	int size = args.length;
	for (int i = 1; i <= size; i++) {
	stmt.setObject(i, args[i - 1]);// 數組下標從0開始
	}
	if (size < num) {
	for (int k = size + 1; k <= num; k++) {
	stmt.setObject(k, null);// 數組下標從0開始
	}
	}
	boolean b = stmt.execute();
	return b;
	}


	public static void getMetaDate() throws Exception {// 獲取數據庫元素數據
	conn = DBUtils.getConnORCALE();
	DatabaseMetaData dmd = conn.getMetaData();
	System.out.println(dmd.getDatabaseMajorVersion());
	System.out.println(dmd.getDatabaseProductName());
	System.out.println(dmd.getDatabaseProductVersion());
	System.out.println(dmd.getDatabaseMinorVersion());
	}


	public static String[] getColumnNamesFromMySQL(String sql) throws Exception {
	conn = DBUtils.getConnMySQL();
	return getColumnName(sql);


	}


	public static String[] getColumnNamesFromOrcale(String sql)
	throws Exception {
	conn = DBUtils.getConnORCALE();
	return getColumnName(sql);


	}


	private static String[] getColumnName(String sql) throws Exception {// 返回表中所有的列名
	conn = DBUtils.getConnORCALE();
	st = conn.createStatement();
	rs = st.executeQuery(sql);
	ResultSetMetaData rsmd = rs.getMetaData();
	int num = rsmd.getColumnCount();
	System.out.println("ColumnCount=" + num);
	String[] strs = new String[num];
	// 顯示列名
	for (int i = 1; i <= rsmd.getColumnCount(); i++) {
	String str = rsmd.getColumnName(i);
	strs[i - 1] = str;
	System.out.print(str + "\t");
	}
	return strs;
	}


	public static void getColumnDataFromMySQL(String sql) throws Exception {//