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); 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 { 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 {// 输出表中的数据 conn = DBUtils.getConnMySQL(); getColumnData(sql); } public static void getColumnDataFromORCALEL(String sql) throws Exception {// 输出表中的数据 conn = DBUtils.getConnORCALE(); getColumnData(sql); } public static void getColumnData(String sql) throws Exception {// 输出表中的数据 st = conn.createStatement(); rs = st.executeQuery(sql); ResultSetMetaData rsmd = rs.getMetaData(); System.out .println("/n------------------------------------------------------------------------------------------------------------------------"); while (rs.next()) { for (int i = 1; i <= rsmd.getColumnCount(); i++) { System.out.print(rs.getString(i) + "/t"); } System.out.println(); } System.out .println("------------------------------------------------------------------------------------------------------------------------"); } public static void getTableDataFromOrcale(String sql) throws Exception {// 输出表的列名 // 和表中的全部数据 conn = DBUtils.getConnORCALE(); getTableData(sql); } public static void getTableDataFromMysql(String sql) throws Exception {// 输出表的列名 // 和表中的全部数据 conn = DBUtils.getConnMySQL(); getTableData(sql); } private static void getTableData(String sql) throws SQLException { // getTableDataFromMysql // getTableDataFromOrcale 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"); } System.out .println("/n------------------------------------------------------------------------------------------------------------------------"); while (rs.next()) { for (int i = 1; i <= rsmd.getColumnCount(); i++) { System.out.print(rs.getString(i) + "/t"); } System.out.println(); } System.out .println("------------------------------------------------------------------------------------------------------------------------"); }}

로그인 후 복사

본 웹사이트의 성명

본 글의 내용은 네티즌들의 자발적인 기여로 작성되었으며, 저작권은 원저작자에게 있습니다. 본 사이트는 이에 상응하는 법적 책임을 지지 않습니다. 표절이나 침해가 의심되는 콘텐츠를 발견한 경우 admin@php.cn으로 문의하세요.

핫 AI 도구

Undresser.AI Undress

사실적인 누드 사진을 만들기 위한 AI 기반 앱

AI Clothes Remover

사진에서 옷을 제거하는 온라인 AI 도구입니다.

Undress AI Tool

무료로 이미지를 벗다

Clothoff.io

AI 옷 제거제

Video Face Swap

완전히 무료인 AI 얼굴 교환 도구를 사용하여 모든 비디오의 얼굴을 쉽게 바꾸세요!

뜨거운 도구

메모장++7.3.1

사용하기 쉬운 무료 코드 편집기

SublimeText3 중국어 버전

중국어 버전, 사용하기 매우 쉽습니다.

스튜디오 13.0.1 보내기

강력한 PHP 통합 개발 환경

드림위버 CS6

시각적 웹 개발 도구

SublimeText3 Mac 버전

신 수준의 코드 편집 소프트웨어(SublimeText3)

뜨거운 주제

Gmail 이메일의 로그인 입구는 어디에 있나요?

7751

자바 튜토리얼

1643

Cakephp 튜토리얼

1398

라라벨 튜토리얼

1293

PHP 튜토리얼

1234

Related knowledge

MySQL에서 인덱스를 사용하는 것보다 전체 테이블 스캔이 더 빠를 수 있습니까? Apr 09, 2025 am 12:05 AM

전체 테이블 스캔은 MySQL에서 인덱스를 사용하는 것보다 빠를 수 있습니다. 특정 사례는 다음과 같습니다. 1) 데이터 볼륨은 작습니다. 2) 쿼리가 많은 양의 데이터를 반환 할 때; 3) 인덱스 열이 매우 선택적이지 않은 경우; 4) 복잡한 쿼리시. 쿼리 계획을 분석하고 인덱스 최적화, 과도한 인덱스를 피하고 정기적으로 테이블을 유지 관리하면 실제 응용 프로그램에서 최상의 선택을 할 수 있습니다.

Windows 7에 MySQL을 설치할 수 있습니까? Apr 08, 2025 pm 03:21 PM

예, MySQL은 Windows 7에 설치 될 수 있으며 Microsoft는 Windows 7 지원을 중단했지만 MySQL은 여전히 호환됩니다. 그러나 설치 프로세스 중에 다음 지점이 표시되어야합니다. Windows 용 MySQL 설치 프로그램을 다운로드하십시오. MySQL의 적절한 버전 (커뮤니티 또는 기업)을 선택하십시오. 설치 프로세스 중에 적절한 설치 디렉토리 및 문자를 선택하십시오. 루트 사용자 비밀번호를 설정하고 올바르게 유지하십시오. 테스트를 위해 데이터베이스에 연결하십시오. Windows 7의 호환성 및 보안 문제에 주목하고 지원되는 운영 체제로 업그레이드하는 것이 좋습니다.

InnoDB 전체 텍스트 검색 기능을 설명하십시오. Apr 02, 2025 pm 06:09 PM

InnoDB의 전체 텍스트 검색 기능은 매우 강력하여 데이터베이스 쿼리 효율성과 대량의 텍스트 데이터를 처리 할 수있는 능력을 크게 향상시킬 수 있습니다. 1) InnoDB는 기본 및 고급 검색 쿼리를 지원하는 역 색인화를 통해 전체 텍스트 검색을 구현합니다. 2) 매치 및 키워드를 사용하여 검색, 부울 모드 및 문구 검색을 지원합니다. 3) 최적화 방법에는 워드 세분화 기술 사용, 인덱스의 주기적 재건 및 캐시 크기 조정, 성능과 정확도를 향상시키는 것이 포함됩니다.

InnoDB에서 클러스터 된 인덱스와 비 클러스터 된 인덱스 (2 차 지수)의 차이. Apr 02, 2025 pm 06:25 PM

클러스터 인덱스와 비 클러스터 인덱스의 차이점은 1. 클러스터 된 인덱스는 인덱스 구조에 데이터 행을 저장하며, 이는 기본 키 및 범위별로 쿼리에 적합합니다. 2. 클러스터되지 않은 인덱스는 인덱스 키 값과 포인터를 데이터 행으로 저장하며 비 예산 키 열 쿼리에 적합합니다.

MySQL : 쉽게 학습하기위한 간단한 개념 Apr 10, 2025 am 09:29 AM

MySQL은 오픈 소스 관계형 데이터베이스 관리 시스템입니다. 1) 데이터베이스 및 테이블 작성 : CreateAbase 및 CreateTable 명령을 사용하십시오. 2) 기본 작업 : 삽입, 업데이트, 삭제 및 선택. 3) 고급 운영 : 가입, 하위 쿼리 및 거래 처리. 4) 디버깅 기술 : 확인, 데이터 유형 및 권한을 확인하십시오. 5) 최적화 제안 : 인덱스 사용, 선택을 피하고 거래를 사용하십시오.

다양한 유형의 MySQL 인덱스 (B-Tree, Hash, Full-Text, Spatial)를 설명하십시오. Apr 02, 2025 pm 07:05 PM

MySQL은 B-Tree, Hash, Full-Text 및 Spatial의 4 가지 인덱스 유형을 지원합니다. 1.B- 트리 색인은 동일한 값 검색, 범위 쿼리 및 정렬에 적합합니다. 2. 해시 인덱스는 동일한 값 검색에 적합하지만 범위 쿼리 및 정렬을 지원하지 않습니다. 3. 전체 텍스트 색인은 전체 텍스트 검색에 사용되며 다량의 텍스트 데이터를 처리하는 데 적합합니다. 4. 공간 지수는 지리 공간 데이터 쿼리에 사용되며 GIS 응용 프로그램에 적합합니다.

MySQL 사용자와 데이터베이스의 관계 Apr 08, 2025 pm 07:15 PM

MySQL 데이터베이스에서 사용자와 데이터베이스 간의 관계는 권한과 테이블로 정의됩니다. 사용자는 데이터베이스에 액세스 할 수있는 사용자 이름과 비밀번호가 있습니다. 권한은 보조금 명령을 통해 부여되며 테이블은 Create Table 명령에 의해 생성됩니다. 사용자와 데이터베이스 간의 관계를 설정하려면 데이터베이스를 작성하고 사용자를 생성 한 다음 권한을 부여해야합니다.

MySQL과 Mariadb가 공존 할 수 있습니다 Apr 08, 2025 pm 02:27 PM

MySQL 및 MariaDB는 공존 할 수 있지만주의해서 구성해야합니다. 열쇠는 각 데이터베이스에 다른 포트 번호와 데이터 디렉토리를 할당하고 메모리 할당 및 캐시 크기와 같은 매개 변수를 조정하는 것입니다. 연결 풀링, 애플리케이션 구성 및 버전 차이도 고려해야하며 함정을 피하기 위해 신중하게 테스트하고 계획해야합니다. 두 개의 데이터베이스를 동시에 실행하면 리소스가 제한되는 상황에서 성능 문제가 발생할 수 있습니다.

See all articles