Java JDBC(一)

JDBC概述

JDBC(Java Data Base Connectivity,java数据库连接)是一种用于执行SQL语句的Java API,可以为多种关系数据库提供统一访问,它由一组用Java语言编写的类和接口组成。是Java访问数据库的标准规范
JDBC提供了一种基准,据此可以构建更高级的工具和接口,使数据库开发人员能够编写数据库应用程序。
JDBC需要连接驱动,驱动是两个设备要进行通信,满足一定通信数据格式,数据格式由设备提供商规定,设备提供商为设备提供驱动软件,通过软件可以与该设备进行通信

JDBC原理

ava提供访问数据库规范称为JDBC,而生产厂商提供规范的实现类称为驱动


image.png

JDBC是接口,驱动是接口的实现,没有驱动将无法完成数据库连接,从而不能操作数据库!每个数据库厂商都需要提供自己的驱动,用来连接自己公司的数据库,也就是说驱动一般都由数据库生成厂商提供

JDBC开发步骤

  • 注册驱动.
  • 获得连接.
  • 获得语句执行平台
  • 执行sql语句
  • 处理结果
  • 释放资源.

导入驱动jar包

  • 创建lib目录,用于存放当前项目需要的所有jar包
  • 选择jar包,右键执行build path / Add to Build Path


    image.png

API详解:注册驱动

代码:

Class.forName("com.mysql.jdbc.Driver");

JDBC规范定义驱动接口:java.sql.Driver,MySql驱动包提供了实现类:com.mysql.jdbc.Driver
DriverManager工具类,提供注册驱动的方法 registerDriver(),方法的参数是java.sql.Driver,所以我们可以通过如下语句进行注册:
DriverManager.registerDriver(new com.mysql.jdbc.Driver());

以上代码不推荐使用,存在两方面不足
1.硬编码,后期不易于程序扩展和维护
2.驱动被注册两次。
通常开发我们使用Class.forName() 加载一个使用字符串描述的驱动类。
如果使用Class.forName()将类加载到内存,该类的静态代码将自动执行。
通过查询com.mysql.jdbc.Driver源码,我们发现Driver类“主动”将自己进行注册

public class Driver extends NonRegisteringDriver implements java.sql.Driver {
    static {
        try {
            java.sql.DriverManager.registerDriver(new Driver());
        } catch (SQLException E) {
            throw new RuntimeException("Can't register driver!");
        }
    }
   ...
}

API详解:获得链接

代码:

Connection con = DriverManager.getConnection("jdbc:mysql://localhost:3306/mydb", "root", "123456");

获取连接需要方法 DriverManager.getConnection(url, username, password),三个参数分别表示,url 需要连接数据库的位置(网址user用户名 password 密码

url比较复杂,下面是mysql的url:
jdbc:mysql://localhost:3306/mydb

JDBC规定url的格式由三部分组成,每个部分中间使用冒号分隔。

第一部分是jdbc,这是固定的;
第二部分是数据库名称,那么连接mysql数据库,第二部分当然是mysql了;
第三部分是由数据库厂商规定的,我们需要了解每个数据库厂商的要求,mysql的第三部分分别由数据库服务器的IP地址(localhost)、端口号(3306),以及DATABASE名称(mydb)组成。

预处理对象executeUpdate方法

通过预处理对象的executeUpdate方法,完成记录的insert\update\delete语句的执行。操作格式统一如下:

  • 注册驱动
  • 获取连接
  • 获取预处理对象
  • SQL语句占位符设置实际参数
  • 执行SQL语句
  • 释放资源
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;


public class Test {
    public static void main(String[] args) throws Exception {
        updata();
    }
    public static void updata() throws Exception {
        // 注册驱动
        Class.forName("com.mysql.jdbc.Driver");
        
        // 获取连接
        Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/jdbc", "root", "123456");
        
        // 获得预处理对象中
        String sql = "UPDATE goods SET name=? where id=?";
        PreparedStatement stat = conn.prepareStatement(sql);
        
        // SQL语句占位符设置实际参数
        stat.setString(1, "数码产品");
        stat.setInt(2, 1);
        
        // 执行SQL语句
        int line = stat.executeUpdate();
        System.out.println("更新记录数:" + line);
        
        // 释放资源
        stat.close();
        conn.close();
    }
}

具体的可以看看已下教程
https://www.yiibai.com/jdbc/

JDBC工具类

“获得数据库连接”操作,将在以后的增删改查所有功能中都存在,可以封装工具类JDBCUtils。提供获取连接对象的方法,从而达到代码的重复利用。
该工具类提供方法:public static Connection getConnection ()。
代码如下:

package com.cuzz;
/*
 *  实现JDBC的工具类
 *  定义方法,直接返回数据库的连接对象
 *  
 *  写关闭方法
 */

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

public class JDBCUtils {
    private JDBCUtils(){}
    private static Connection con ;
    
    static{
        try{
            Class.forName("com.mysql.jdbc.Driver");
            String url = "jdbc:mysql://localhost:3306/mybase";
            String username="root";
            String password="123";
            con = DriverManager.getConnection(url, username, password);
        }catch(Exception ex){
            throw new RuntimeException(ex+"数据库连接失败");
        }
    }
    
    /*
     * 定义静态方法,返回数据库的连接对象
     */
    public static Connection getConnection(){
        return con;
    }
    
    
    public static void close(Connection con,Statement stat){
         
         if(stat!=null){
             try{
                 stat.close();
             }catch(SQLException ex){}
         }
         
         if(con!=null){
             try{
                 con.close();
             }catch(SQLException ex){}
         } 
    }
    
    
    public static void close(Connection con, Statement stat, ResultSet rs){
         if(rs!=null){
             try{
                 rs.close();
             }catch(SQLException ex){}
         }
         
         if(stat!=null){
             try{
                 stat.close();
             }catch(SQLException ex){}
         }
         
         if(con!=null){
             try{
                 con.close();
             }catch(SQLException ex){}
         } 
    }
}

properties配置文件

开发中获得连接的4个参数(驱动、URL、用户名、密码)通常都存在配置文件中,方便后期维护,程序如果需要更换数据库,只需要修改配置文件即可。
通常情况下,我们习惯使用properties文件,此文件我们将做如下要求:

  • 文件位置:任意,建议src下
  • 文件名称:任意,扩展名为properties
  • 文件内容:一行一组数据,格式是"key=value"
    key命名自定义,如果是多个单词,习惯使用点分隔。例如:jdbc.driver
    value值不支持中文,如果需要使用非英文字符,将进行unicode转换

创建配置文件

在项目跟目录下,创建文件,输入"db.properties"文件名
在"db.properties"文件中写下配置

driver=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/mydb
user=root
password=123456

加载配置文件:Properties对象

JDBCUtilsConfig.java中编写代码

import java.io.InputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.util.Properties;

/*
 *  编写数据库连接的工具类,JDBC工具类
 *  获取连接对象采用读取配置文件方式
 *  读取文件获取连接,执行一次,static{}
 */
public class JDBCUtilsConfig {
    private static Connection con ;
    private static String driverClass;
    private static String url;
    private static String username;
    private static String password;
    
    static{
        try{
            readConfig();
            Class.forName(driverClass);
            con = DriverManager.getConnection(url, username, password);
        }catch(Exception ex){
            throw new RuntimeException("数据库连接失败");
        }
    }
    
    private static void readConfig()throws Exception{
        InputStream in = JDBCUtilsConfig.class.getClassLoader().getResourceAsStream("database.properties");
         Properties pro = new Properties();
         pro.load(in);
         driverClass=pro.getProperty("driver");
         url = pro.getProperty("url");
         username = pro.getProperty("username");
         password = pro.getProperty("password");
    }
    
    public static Connection getConnection(){
        return con;
    }
}
最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。