Java-JDBC详解

比眉伴天荒 2021-09-25 02:50 298阅读 0赞

**Java-JDBC详解**

JDBC常用的接口和类库

1.DriverManager：驱动JDBC驱动的服务类

2.Connection：数据库连接对象

3. Statement：执行sql的对象

4. PreparedStatement：执行sql的对象

5. ResultSet：结果集对象,封装查询结果

使用JDBC的步骤

登录练习

JDBC工具类

登录代码

创作不易，如果本篇博客对您有一定的帮助，大家记得留言+点赞哦。

--------------------

JDBC是Java程序连接数据库的一个重要接口，是搭建Java程序与数据库连接的重要桥梁，描述了一个访问关系型数据库的标准类库，并且为数据库厂商提供了一个标准的体系结构。JDBC允许用户访问任何形式的表格数据，执行流程：1.连接数据源      2.为数据库传递查询和更新指令   3.处理数据库响应并返回的结果。

### **如何对常用的SQL语句还不熟悉那就先跳转到这里吧！！[史上超强最常用SQL语句大全][SQL]** ###

## JDBC常用的接口和类库 ##

### **1.DriverManager：驱动JDBC驱动的服务类** ###

**主要功能是注册驱动、获取Connection对象**

** 1. 注册驱动：告诉程序该使用哪一个数据库驱动jar**

//注册与给定的驱动程序 DriverManager
    static void registerDriver(Driver driver) ;
    
    
    //写代码使用 
    Class.forName("com.mysql.jdbc.Driver");

**2. 获取数据库连接：**

> **方法**：static Connection getConnection(String url, String user, String password) 
> 
> 参数：
> 
>           url：指定连接的路径
> 
>           user：用户名
> 
>           password：密码 
> 
>           语法：jdbc:mysql://ip地址(域名):端口号/数据库名称,user,password
> 
>           细节：如果连接的是本机mysql服务器，并且mysql服务默认端口是3306，则url可以简写为：jdbc:mysql:///数据库名称

//获取数据库连接对象Connection
    Connection conn=DriverManager.getConnection("jdbc:mysql://localhost:3306/db3","root","root");

### **2.Connection：数据库连接对象** ###

**每一个Connection代表一个物理连接会话，要访问数据库，必须先获得数据库连接。**

**常用方法：**

>        1. 获取执行sql 的对象
> 
>               Statement createStatement()
> 
>               PreparedStatement prepareStatement(String sql)  
> 
>        2. 管理事务：
> 
>              开启事务：setAutoCommit(boolean autoCommit) ：调用该方法设置参数为false，即开启事务
> 
>              提交事务：commit() 
> 
>              回滚事务：rollback()

### **3. Statement：执行sql的对象** ###

**Statemet是一个执行sql语句的工具接口，该对象既可以执行DDL、DCL语句，也可以执行DML语句，当执行SQL查询时，它会返回查询到的结果集。**

主要方法

>                 1. boolean execute(String sql) ：该方法可以执行任意的sql语句。**了解即可**  
> 
>                 2. int executeUpdate(String sql) ：执行DML（insert、update、delete）语句、DDL(create，alter、drop)语句
> 
>                        返回值：影响的行数，可以通过这个影响的行数判断DML语句是否执行成功
> 
>                        返回值>0的则执行成功，反之，则失败。
> 
>                 3. ResultSet executeQuery(String sql)  ：执行DQL（select)语句
> 
>                        该方法只能用于执行查询语句，并返回查询结果对应的ResultSet对象。

### **4. PreparedStatement：执行sql的对象** ###

**PreparedStatement是一个预编译的Statement对象，PreparedStatement是Statement的子接口，它允许数据库预编译SQL语句，以后每次只需改变SQL命令参数，避免数据库每次都编译SQL语句，因此性能更好。预编译SQL解决了SQL注入的问题， 预编译的SQL：参数使用?作为占位符。**

**常用方法**

>         boolean execute()：执行此PreparedStatement对象中的SQL语句，该语句可以是任何类型的SQL语句。
> 
>         int executeUpdate() ：执行此PreparedStatement对象中的SQL语句，它必须是一个SQL数据操纵语言（DML）语句，比如`INSERT`，`UPDATE`或 `DELETE`; 或不返回任何内容的SQL语句，例如DDL语句。
> 
>        ResultSet executeQuery() ：在此PreparedStatement对象中执行SQL查询，并返回`ResultSet`查询生成的对象。

**由于PreparedStatement是Statement的子接口，所以他们的常用方法很一致。PreparedStatement主要是预编译SQL，解决了SQL注入的问题，提高性能。**

### **5. ResultSet：结果集对象,封装查询结果** ###

**ResultSet是一个结果对象，该对象包含查询结果的方法，ResultSet可以通过索引或列名类获得列中的数据。**

**常用方法**

>             boolean next(): 游标向下移动一行，判断当前行是否是最后一行末尾(是否有数据)，如果是，则返回false，如果不是则返回true
> 
>             void beforeFirst()：将ResultSet的记录指针定位到首行之前，初始位置。
> 
>             boolean absolute(int row)：将结果集的记录指针移动到第row行。
> 
>             getXxx(参数):获取数据
> 
>                  Xxx：代表数据类型   如： int getInt() ,    String getString()
> 
>                  参数：
> 
>                     1. int：代表列的编号,从1开始   如： getString(1)
> 
>                     2. String：代表列名称。 如： getDouble("balance")

## 使用JDBC的步骤 ##

<table> 
 <tbody> 
 <tr> 
 <td style="width:487px;"> 静态编译SQL步骤：使用Statement &nbsp; &nbsp; 1.&nbsp;导入驱动jar包 mysql-connector-java-5.1.37-bin.jar &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;1.复制mysql-connector-java-5.1.37-bin.jar到项目的libs目录下 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;2.右键--&gt;Add As Library &nbsp; 2.&nbsp;注册驱动 &nbsp;&nbsp;3.&nbsp;获取数据库连接对象 Connection &nbsp; 4.&nbsp;定义sql &nbsp;&nbsp;5.&nbsp;获取执行sql语句的对象 Statement &nbsp; 6.&nbsp;执行sql，接受返回结果 &nbsp;&nbsp;7.&nbsp;处理结果 &nbsp;&nbsp;8.&nbsp;释放资源 </td> 
 <td> 动态编译SQL步骤：使用PreparedStatement对象 &nbsp; &nbsp;1.&nbsp;导入驱动jar包 mysql-connector-java-5.1.37-bin.jar &nbsp;2.&nbsp;注册驱动 &nbsp;3.&nbsp;获取数据库连接对象 Connection &nbsp;4.&nbsp;定义sql &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; * 注意：sql的参数使用？作为占位符。 如：select * from user where username = ? and password = ?; &nbsp; 5.&nbsp;获取执行sql语句的对象 PreparedStatement&nbsp;&nbsp;Connection.prepareStatement(String sql)&nbsp; &nbsp; 6.&nbsp;给？赋值： &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; * 方法： setXxx(参数1,参数2) &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; * 参数1：？的位置编号 从1 开始 &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; * 参数2：？的值 &nbsp; 7.&nbsp;执行sql，接受返回结果，不需要传递sql语句 &nbsp; 8.&nbsp;处理结果 &nbsp; 9.&nbsp;释放资源 </td> 
 </tr> 
 </tbody> 
</table>

public static void main(String[]args)throwsException{
    	//1.导入驱动jar包
    	//2.注册驱动
    	Class.forName("com.mysql.jdbc.Driver");
    	//3.获取数据库连接对象Connection
    	Connection conn=DriverManager.getConnection("jdbc:mysql://localhost:3306/db3","root","root");
    	//4.定义SQL
    	Stringsql="update emp set salary=8001 WHERE id=1001;";
    	//5.执行SQL语句对象Statement
    	Statementstmt=conn.createStatement();
    	//6.执行SQL，接收返回结果
    	intcount=stmt.executeUpdate(sql);
    	//7.处理结果
    	System.out.println(count);
    	//8.释放资源
    	stmt.close();
    	conn.close();
    }

## 登录练习 ##

### JDBC工具类 ###

import java.io.FileReader;
    import java.io.IOException;
    import java.net.URL;
    import java.sql.*;
    import java.util.Properties;
    
    /**
     * JDBC工具类
     */
    public class JDBCUtils {
        private static String url;
        private static String user;
        private static String password;
        private static String driver;
        /**
         * 文件的读取，只需要读取一次即可拿到这些值。使用静态代码块
         */
        static{
            //读取资源文件，获取值。
    
            try {
                //1. 创建Properties集合类。
                Properties pro = new Properties();
    
                //获取src路径下的文件的方式--->ClassLoader 类加载器
                ClassLoader classLoader = JDBCUtils.class.getClassLoader();
                URL res  = classLoader.getResource("jdbc.properties");
                String path = res.getPath();
              
                //2. 加载文件
                pro.load(new FileReader(path));
    
                //3. 获取数据，赋值
                url = pro.getProperty("url");
                user = pro.getProperty("user");
                password = pro.getProperty("password");
                driver = pro.getProperty("driver");
                //4. 注册驱动
                Class.forName(driver);
            } catch (IOException e) {
                e.printStackTrace();
            } catch (ClassNotFoundException e) {
                e.printStackTrace();
            }
        }
    
    
        /**
         * 获取连接
         * @return 连接对象
         */
        public static Connection getConnection() throws SQLException {
    
            return DriverManager.getConnection(url, user, password);
        }
    
        /**
         * 释放资源
         * @param stmt
         * @param conn
         */
        public static void close(Statement stmt,Connection conn){
            if( stmt != null){
                try {
                    stmt.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
    
            if( conn != null){
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
    
    
        /**
         * 释放资源
         * @param stmt
         * @param conn
         */
        public static void close(ResultSet rs,Statement stmt, Connection conn){
            if( rs != null){
                try {
                    rs.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
    
            if( stmt != null){
                try {
                    stmt.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
    
            if( conn != null){
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
    
    }

### 登录代码 ###

public class DemoLogin {
        public static void main(String[] args) {
            Scanner sc = new Scanner(System.in);
            System.out.println("请输入账号：");
            String userName = sc.nextLine();
            System.out.println("请输入密码：");
            String password = sc.nextLine();
            boolean flag = new DemoLogin().login2(userName, password);
            if (flag) {
                System.out.println("登录成功！");
            } else {
                System.out.println("账号或密码错误！");
            }
    
        }
    
        public boolean login(String name, String password) {
            //账号密码正确性校验
            if (name == null || password == null) {
                return false;
            }
            Connection conn = null;
            Statement statement = null;
            ResultSet resultSet = null;
            try {
                conn = JDBCUtils.getConn();
                statement = conn.createStatement();
                String sql = "SELECT*FROM login WHERE username='" + name + "'andpassword='" + password + "';";
                System.out.println(sql);
                resultSet = statement.executeQuery(sql);
                return resultSet.next();
            } catch (SQLException throwables) {
                throwables.printStackTrace();
            } finally {
                JDBCUtils.close(conn, statement, resultSet);
            }
            return false;
        }
    
    
        //使用PreparedStatement传参
        public boolean login2(String name, String password) {
            //账号密码正确性校验
            if (name == null || password == null) {
                return false;
            }
    
            Connection conn = null;
            PreparedStatement statement = null;
            ResultSet resultSet = null;
            try {
                conn = JDBCUtils.getConn();
                String sql = "SELECT*FROM login WHERE username=? and password=?;";
                //预编译SQL
                statement = conn.prepareStatement(sql);
                System.out.println(sql);
                //给参数赋值
                statement.setString(1, name);
                statement.setString(2, password);
                //执行查询
                resultSet = statement.executeQuery();
                return resultSet.next();
            } catch (SQLException throwables) {
                throwables.printStackTrace();
            } finally {
                JDBCUtils.close(conn, statement, resultSet);
            }
            return false;
    
        }
    }

## **重磅福利**：如果觉得以上代码很麻烦请跳转到下一篇博客《[Java-Spring JDBC][]》。你会发现只要会写SQL语句就行了，剩下的框架都帮你做好了。 ##

## **创作不易，如果本篇博客对您有一定的帮助，大家记得留言+点赞哦。**   ##

[SQL]: https://blog.csdn.net/promsing/article/details/112793260
[Java-Spring JDBC]: https://blog.csdn.net/promsing/article/details/113716508