JDBC接口核心的API、Statement接口详解

一、JDBC接口核心的API
在JDK API的java.sql.* 和 javax.sql.*下面查看

1、Driver接口：表示java驱动程序接口。所有的具体的数据库厂商要来实现此接口。
1）connect(url, properties): 连接数据库的方法。
url: 连接数据库的URL
URL语法： jdbc协议:数据库子协议://主机:端口/数据库
user：数据库的用户名
password：数据库用户密码

2、DriverManager类：驱动管理器类，用于管理所有注册的驱动程序
1）registerDriver(driver) : 注册驱动类对象
2）Connection getConnection(url,user,password); 获取连接对象

3、Connection接口：表示java程序和数据库的连接对象。
1）Statement createStatement() ：创建Statement对象
2）PreparedStatement prepareStatement(String sql) 创建PreparedStatement对象
3）CallableStatement prepareCall(String sql) 创建CallableStatement对象

4、Statement接口：用于执行静态的sql语句
1）int executeUpdate(String sql) ：执行静态的更新sql语句（DDL，DML）
2）ResultSet executeQuery(String sql) ：执行的静态的查询sql语句（DQL）

5、PreparedStatement接口（Statement接口的子接口）：用于执行预编译sql语句
1） int executeUpdate() ：执行预编译的更新sql语句（DDL，DML）
2）ResultSet executeQuery() ：执行预编译的查询sql语句（DQL）

6、CallableStatement接口（PreparedStatement接口的子接口）：用于执行存储过程的sql语句（call xxx）
1）ResultSet executeQuery() ：调用存储过程的方法

7、ResultSet接口：用于封装查询出来的数据
1）boolean next() ：将光标移动到下一行
2）getXX() : 获取列的值

二、使用Statement执行sql语句
1、执行DDL语句

package sram.jdbc.connection;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;

import org.junit.Test;

/**
 * 使用Statement对象执行静态sql语句
 */
public class Demo2 {
private String url = "jdbc:mysql://localhost:3306/emp_system";
private String user = "root";
private String password = "root";
/**
 * 执行DDL语句(创建表)
 */
@Test
public void test1(){
        Connection conn = null;
        Statement stmt = null;
try {
//1.驱动注册程序
            Class.forName("com.mysql.jdbc.Driver");
//2.获取连接对象
            conn = DriverManager.getConnection(url, user, password);
//3.创建Statement
            stmt =  conn.createStatement();
//4.准备sql
            String sql = "CREATE TABLE dept(id INT PRIMARY KEY AUTO_INCREMENT,NAME VARCHAR(20),BossName VARCHAR(20))";
//5.发送sql语句，执行sql语句,得到返回结果
int count = stmt.executeUpdate(sql);
//6.校验是否发送成功
            System.out.println("影响了"+count+"行！");
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
throw new RuntimeException(e);
        } catch (SQLException e) {
            e.printStackTrace();
throw new RuntimeException(e);
        }finally{
//7.关闭连接(顺序:后打开的先关闭)
if(stmt!=null){
try {
                    stmt.close();
                } catch (SQLException e) {
                    e.printStackTrace();
throw new RuntimeException(e);
                }
            }
if(conn!=null){
try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
throw new RuntimeException(e);
                }
            }
        }
    }   
}

2、执行DML语句：和执行DDL语句一样，仅sql语句不同
1）插入：

String sql = "INSERT INTO dept(NAME,BossName) VALUES('软件开发部','张三')";

2）更新：

String sql = "UPDATE dept SET NAME='销售部' WHERE id='1'";

3）删除：

String sql = "DELETE FROM dept WHERE id=2";

3、封装重复代码，引入变量
1）封装重复代码：

package sram.util.jdbc;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;

/**
 * jdbc工具类
 */
public class JdbcUtil {
private static String url = "jdbc:mysql://localhost:3306/emp_system";
private static String user = "root";
private static String password = "root";

/**
 * 静态代码块中(只加载一次)
 */
static{
//注册驱动程序
try {
            Class.forName("com.mysql.jdbc.Driver");
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
            System.out.println("驱动程序注册出错");
        }
    }

/**
 * 抽取获取连接对象的方法
 */
public static Connection getConnection(){
try {
            Connection conn = DriverManager.getConnection(url, user, password);
return conn;
        } catch (SQLException e) {
            e.printStackTrace();
throw new RuntimeException(e);
        }
    }

/**
 * 释放资源的方法
 */
public static void close(Connection conn,Statement stmt){
if(stmt!=null){
try {
                stmt.close();
            } catch (SQLException e) {
                e.printStackTrace();
throw new RuntimeException(e);
            }
        }
if(conn!=null){
try {
                conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
throw new RuntimeException(e);
            }
        }
    }   
}

2）使用封装好的类，并引入变量

package sram.jdbc.connection;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;

import org.junit.Test;

import sram.util.jdbc.JdbcUtil;

/**
 * 使用Statement对象执行静态sql语句
 */
public class Demo2 {
/**
 * 执行DTL/DML语句
 */
private int id = 4;
@Test
public void test(){
        Connection conn = null;
        Statement stmt = null;
try {
//1.驱动注册程序
//2.获取连接对象
//使用封装类
            conn = JdbcUtil.getConnection();

//3.创建Statement
            stmt =  conn.createStatement();
//4.准备sql
//String sql = "CREATE TABLE dept(id INT PRIMARY KEY AUTO_INCREMENT,NAME VARCHAR(20),BossName VARCHAR(20))";
//String sql = "INSERT INTO dept(NAME,BossName) VALUES('软件开发部','张三')";
//String sql = "UPDATE dept SET NAME='销售部' WHERE id=1";

//使用变量形式
            String sql = "DELETE FROM dept WHERE id="+id;
//5.发送sql语句，执行sql语句,得到返回结果
int count = stmt.executeUpdate(sql);
//6.校验是否发送成功
            System.out.println("影响了"+count+"行！");
        } catch (SQLException e) {
            e.printStackTrace();
throw new RuntimeException(e);
        }finally{
//7.关闭连接(顺序:后打开的先关闭)
//使用封装类
            JdbcUtil.close(conn, stmt);
        }
    }   
}

4、执行DQL语句
JDBC接口核心的API、Statement接口详解

package sram.jdbc.connection;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

import org.junit.Test;

import sram.util.jdbc.JdbcUtil;

/**
 * 使用Statement执行DQL语句（查询操作）
 */
public class Demo3 {
@Test
public void test(){
        Connection conn = null;
        Statement stmt = null;
try {
//获取连接
            conn = JdbcUtil.getConnection();
//创建Statement
            stmt = conn.createStatement();
//准备sql
            String sql = "SELECT * FROM dept";
//执行sql
            ResultSet rs = stmt.executeQuery(sql);
/*
 //移动光标
 boolean flag = rs.next();
 if(flag){
 //取出列值
 //通过索引
 /*
 int id = rs.getInt(1);
 String name = rs.getString(2);
 String bossName = rs.getString(3);
 System.out.println(id+","+name+","+bossName);


 //列名称，不区分大小写
 int id = rs.getInt("id");
 String name = rs.getString("name");
 String bossName = rs.getString("bossname");
 System.out.println(id+","+name+","+bossName);
 }*/
//遍历结果
while(rs.next()){
int id = rs.getInt("id");
                String name = rs.getString("name");
                String bossName = rs.getString("bossname");
                System.out.println(id+","+name+","+bossName);
            }
        } catch (SQLException e) {
            e.printStackTrace();
throw new RuntimeException(e);
        }finally{
            JdbcUtil.close(conn, stmt);
        }
    }
}

秒客网

JDBC接口核心的API、Statement接口详解

相关文章