Java JDBC

JDBC 常见使用：

  1. 加载驱动
Class.forName("com.mysql.jdbc.Driver");
  1. 获取数据库连接
    public static Connection getCon() {
        
        // MySQ的URL格式 jdbc:mysql://主机名:端口号/数据库名
        final String url = "jdbc:mysql://localhost:3306/test";
        final String user = "root";
        final String pass = "root";
        
        Connection con = null;
        try {
            // 加载驱动
            Class.forName("com.mysql.jdbc.Driver");
            // 获取数据库连接
            con = DriverManager.getConnection(url, user, pass);
        }
        catch (Exception e) {
            e.printStackTrace();
        }
        
        return con;
    }
  1. 使用 executeQuery 方法执行SQL的查询语句
public static void QueryDemo() throws SQLException {
        // 获取数据库连接
        Connection con = getCon();
        // 准备sql语句
        String sql = "select * from users where ssex = '女'";
        // 获取状态
        Statement state = con.createStatement();
        // 提交查询的sql语句
        ResultSet set = state.executeQuery(sql);
        // 处理结果
        while(set.next()) {
            String name = set.getString("user_name");
            int age = set.getInt("sage");
            System.out.println("姓名：" + name + "， 年龄：" + age);
        }
        // 释放资源
        if (set != null) {
            set.close();
        }
        if (con != null) {
            con.close();
        }    
    }
  1. 使用 executeUpdate 方法执行更新的SQL语句（增速改）
    public static int UpdataDemo() throws SQLException {
        int row = -1;
        // 获取连接
        Connection con = getCon();
        // 准备sql语句
        String sql = "UPDATE users SET user_pass = 123123 WHERE sid = 1";
        // 获取状态
        Statement state = con.createStatement();
        // 提交更新(增、删、改)SQL语句
        row = state.executeUpdate(sql);
        // 处理结果
        System.out.println("影响行数：" + row);
        // 释放资源
        con.close();
        return row;
    }
  1. execute 方法增删查改都可以提交
public static void executeDemo() throws SQLException {
        // 获取连接
        Connection con = getCon();
        // 准备sql语句
        String sql = "UPDATE users SET user_pass = 123123 WHERE sid = 1";
        // 获取状态
        Statement state = con.createStatement();
        // 提交更新(增、删、查、改)SQL语句
         boolean isResult = state.execute(sql);
        if (isResult == true) {
            // 获取结果集
            ResultSet set = state.getResultSet();
            // 处理结果
            // 省略。。。
        }
        else {
            // 获取影响行数
            int row = state.getUpdateCount();
            System.out.println("影响行数：" + row);
        }
    }
  1. 使用 preparStatement 预编译状态执行SQL语句
public static int preExceuteDemo(String name, String pass) throws SQLException {
        int row = -1;
        // 获取连接
        Connection con = getCon();
        // 准备sql
        String sql = "UPDATE users SET user_pass = ? WHERE user_name = ?";
        // 获取预编译状态
        PreparedStatement state = con.prepareStatement(sql);
        // 设置参数
        state.setString(1, pass);
        state.setString(2, name);
        // 提交sql语句
        row = state.executeUpdate();
        // 处理结果
        System.out.println("影响行数：" + row);
        // 释放资源
        state.close();
        
        return row;
    }
  1. 使用 CallableStatement 状态 调用存储过程
public static String callPreDemo(String name) throws SQLException {
        String id = null;
        // 获取数据库连接
        Connection con = getCon();
        // 准备调用存储过程的sql语句
        String sql = "{call p_getid(?, ?)}";
        // 获取 callable 预编译状态
        CallableStatement state = con.prepareCall(sql);
        // 设置参数
        state.setString(1, name);
        // 声明输出参数类型
        state.registerOutParameter(2, java.sql.Types.VARCHAR);
        // 执行存储过程
        state.execute();
        // 获取存储过程输出参数
        id = state.getString(2);
        // 处理结果
        System.out.println(name + "的用户id为：" + id);
        // 释放资源
        state.close();
                
        return id;
    }

事务

// 关闭自动提交，提交了 SQL 语句不会立即生效，需要自己手动提交。
con.setAutoCommit(false);
// 手动提交
con.commit();
// 回滚
con.rollback();

完整代码

package com.woniuxy.jdbcdemo;

import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.sql.CallableStatement;
import java.sql.Connection;

public class JDBCDemo {
    
    
    public static void main(String[] args) {
        try {
//            QueryDemo();
//            UpdataDemo();
//            preExceuteDemo("张三", "zs123");
            callPreDemo("王五");
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
    
    public static Connection getCon() {
        
        // jdbc:mysql://主机名:端口号/数据库名
        final String url = "jdbc:mysql://localhost:3306/test";
        final String user = "root";
        final String pass = "root";
        
        Connection con = null;
        try {
            // 加载驱动
            Class.forName("com.mysql.jdbc.Driver");
            // 获取数据库连接
            con = DriverManager.getConnection(url, user, pass);
        }
        catch (Exception e) {
            e.printStackTrace();
        }
        
        return con;
    }
    
    public static void QueryDemo() throws SQLException {
        // 获取数据库连接
        Connection con = getCon();
        // 准备sql语句
        String sql = "select * from users where ssex = '女'";
        // 获取状态
        Statement state = con.createStatement();
        // 提交查询的sql语句
        ResultSet set = state.executeQuery(sql);
        // 处理结果
        while(set.next()) {
            String name = set.getString("user_name");
            int age = set.getInt("sage");
            System.out.println("姓名：" + name + "， 年龄：" + age);
        }
        // 释放资源
        if (set != null) {
            set.close();
        }
        if (con != null) {
            con.close();
        }    
    }
    
    public static int UpdataDemo() throws SQLException {
        int row = -1;
        // 获取连接
        Connection con = getCon();
        // 准备sql语句
        String sql = "UPDATE users SET user_pass = 123123 WHERE sid = 1";
        // 获取状态
        Statement state = con.createStatement();
        // 提交更新(增、删、改)SQL语句
        row = state.executeUpdate(sql);
        // 处理结果
        System.out.println("影响行数：" + row);
        // 释放资源
        con.close();
        return row;
    }
    
    public static void executeDemo() throws SQLException {
        // 获取连接
        Connection con = getCon();
        // 准备sql语句
        String sql = "UPDATE users SET user_pass = 123123 WHERE sid = 1";
        // 获取状态
        Statement state = con.createStatement();
        // 提交更新(增、删、查、改)SQL语句
         boolean isResult = state.execute(sql);
        if (isResult == true) {
            // 获取结果集
            ResultSet set = state.getResultSet();
            // 处理结果
            
        }
        else {
            // 获取影响行数
            int row = state.getUpdateCount();
            System.out.println("影响行数：" + row);
        }
    }
    
    public static int preExceuteDemo(String name, String pass) throws SQLException {
        int row = -1;
        // 获取连接
        Connection con = getCon();
        // 准备sql
        String sql = "UPDATE users SET user_pass = ? WHERE user_name = ?";
        // 获取预编译状态
        PreparedStatement state = con.prepareStatement(sql);
        // 设置参数
        state.setString(1, pass);
        state.setString(2, name);
        // 提交sql语句
        row = state.executeUpdate();
        // 处理结果
        System.out.println("影响行数：" + row);
        // 释放资源
        state.close();
        
        return row;
    }
    
    public static String callPreDemo(String name) throws SQLException {
        String id = null;
        // 获取数据库连接
        Connection con = getCon();
        // 准备调用存储过程的sql语句
        String sql = "{call p_getid(?, ?)}";
        // 获取 callable 预编译状态
        CallableStatement state = con.prepareCall(sql);
        // 设置参数
        state.setString(1, name);
        // 声明输出参数类型
        state.registerOutParameter(2, java.sql.Types.VARCHAR);
        // 执行存储过程
        state.execute();
        // 获取存储过程输出参数
        id = state.getString(2);
        // 处理结果
        System.out.println(name + "的用户id为：" + id);
        // 释放资源
        state.close();
                
        return id;
    }
}
最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
平台声明：文章内容（如有图片或视频亦包括在内）由作者上传并发布，文章内容仅代表作者本人观点，简书系信息发布平台，仅提供信息存储服务。

推荐阅读更多精彩内容