搜索
简帛阁>技术文章>MySQL-JDBC详细介绍

MySQL-JDBC详细介绍

JDBC全称Java database connectivity,是Java和数据库连接的一个桥梁,是一种使用Java操作数据库的规范。

JDBC编程步骤

  • 一、JDBC准备工作
  • 二、初始化资源类
  • 三、执行sql语句类
  • 四、结果集类
  • 五、实现JDBC操作数据库

一、JDBC准备工作

1、因为访问数据库需要用到专门的第三方工具类的jar包,所以我们在使用时需要引入外部jar包,以IDEA编辑器和mysql为例,这里我们需要使用Maven工程,新建Maven工程,在maven官网(https://mvnrepository.com/)搜索mysql,选择 MySQL Connector/J,选择下载量最多的5.1.38版本复制代码到pom.xml文件29行标签dependency里,就会把相应的jar包导入到相应工程内了。

    <!-- https://mvnrepository.com/artifact/mysql/mysql-connector-java -->
    <dependency>
      <groupId>mysql</groupId>
      <artifactId>mysql-connector-java</artifactId>
      <version>5.1.38</version>
    </dependency>

2、定义数据库常量,共4个点

1、数据库驱动:driver=com.mysql.jdbc.Driver
2、连接数据库的url:url=jdbc:mysql://192.168.221.***:3306/kb10mysqltestdb?useUnicode=true&characterEncoding=utf8&useSSL=true
3、数据库登录名:username=******
4、数据库登陆密码:password=******

这里面数据库常量一般建议放在resources过的配置文件里,把数据库常量以键值对的形式写进去,方便后续维护

二、初始化资源类

3、新建一个BaseConfig类,写一个初始化各个配置项的方法,然后用构造器调取该方法作为访问该类的初始化参数,因为涉及到登陆密码等,该类的访问权限可以设置的低一些,尽量不用public。
4、初始化各个配置的方法中,要用到Tread.currentTread().getContextClassLoader().gerResource(“file_name”).getPath()方法获取到文件路径,然后使用专门读取配置文件的类Properties(new一个对象)下面的load方法读取这个这个路径下的方法;接下来,使用properties类下的getProperty方法依次读取“url”“driver”“username”“password”;最后把得到的参数传给当前对象。
5、创建一个注册驱动的getCon()连接方法,把初始化进来的参数传到DriverManager.getConnection方法里;
6、创建一个关闭资源释放资源的close()方法
代码如下:

package cn.kb10.jdbc2;

import java.io.FileReader;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.util.Properties;

class BaseConfig {
    //想隐藏的话,就写内部类
    private class Config{
        String driver;
        String url;
        String username;
        String password;

        public Config(String driver, String url, String username, String password) {
            this.driver = driver;
            this.url = url;
            this.username = username;
            this.password = password;
        }
    }
    private Config config;


    //构造方法也不想被人看到,用代码块
    {
        try {
            init();
            //装载驱动
            Class.forName(config.driver);
        } catch (Exception e) {
            System.err.println(e.getMessage());
        }
    }

    //初始化,读取配置信息
    private void init() throws Exception {
        String path = Thread.currentThread().getContextClassLoader().getResource("datasource.properties").getPath();
        Properties pro = new Properties();
        pro.load(new FileReader(path));
        String url = pro.getProperty("url");
        if (null==url){
            throw new Exception("缺少url配置项异常");
        }
        String driver = pro.getProperty("driver","com.mysql.jdbc.Driver");
        String username = pro.getProperty("username","root");
        String password = pro.getProperty("password","root");
        this.config = new Config(driver,url,username,password);
    }

    protected Connection getCon() throws SQLException {
        return DriverManager.getConnection(config.url,config.username,config.password);
    }

    protected void close(AutoCloseable...acs){
        for (AutoCloseable ac : acs) {
            if (null!=ac){
                try {
                    ac.close();
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        }
    }
}

三、执行sql语句类

7、新建一个继承于BaseConfig的子类,这个子类就3个方法,一个是预编译的方法(这里可以理解为写好的、只缺一个回车键、待执行的sql语句),一个是增删改的方法,一个是查询的方法。
8、首先先写一下预编译的方法,这里用到了PrepareStatement接口,既然是预编译,在使用时就要传入相应的参数,传入哪些参数呢?第一个是之前之前要注册连接上数据库吧,也就是getCon方法执行后的结果;连接上之后,要执行语句吧,第二个参数就是sql语句;第三个参数是是一个通配符数组,就是在sql语句执行时设置where子句的条件,比如说查询学号为XX的成绩,加上这个参数后,可以通过直接控制这个通配符数组来更新条件,当然也可以不要,直接在sql语句里修改,就是麻烦了些不够清晰,也没啥问题。多说一句,这个参数可以是整数也可以是字符串的,所以在参数时设置为Object类型的,通过setObject方法自动识别为对应的数据类型,在使用setObject时,需要注意下遍历数组元素时,mysql是从1开始的,因此索引是从1开是,也就是i+1。输入这几个参数后,直接返回即可。
9、先写增删改方法。增删改的返回值一般是affected n rows,因此我们返回int类型的值。这里我们的参数是sql语句和控制where子句范围的动态数组。首先我们定义一个连接器和预编译器,初始化为null,然后分别执行对应的方法,注册驱动和预编译。到这里基本就结束了,直接返回预编译后更新表格的条数。最后调用close方法倒序依次关闭调用的预编译器和连接器,释放资源。
10、再写查询方法,查询的方法和增删改一样,但是在mysql里返回的结果一般来说是个n*n的二维数组,而在executeQuery方法里返回的是一个ResultSet的结果集对象,这时候我们需要把结果集的内容依次放到二维数组里输出。前面的写法和增删改基本上一样,只不过多了一个结果集的初始化。ResultSet是一个接口,有点像是一个集合。把结果集对象输出为二维数组,首先二维数组的行数是不能确定的,但是列数时可以确定的(这里我们就先不严谨的把ArrayList集合说成为数组,好理解一些),因此我们调用结果集的getMetaDate再调用getColumnCount方法获取总的列数,然后定义一个嵌套ArrayList集合。然后通过结果集的next()方法遍历结果集,对遍历的每一个结果,都放到内层的集合里;一旦结果集读取到列数的最大值,则把这一行(内层集合)作为一个元素赋值给外层元素。等全部读完了,就可以返回这个二维数组了。最后依次倒序关闭结果集、预编译器、连接器。
代码如下:

package cn.kb10.jdbc2;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

public final class BaseDao extends BaseConfig{
    private PreparedStatement getPst(Connection con,String sql, Object...params) throws SQLException {
        PreparedStatement pst = con.prepareStatement(sql);
        if (params.length>0){
            for (int i = 0; i < params.length; i++) {
                pst.setObject(i+1,params[i]);
            }
        }
        return pst;
    }

    public Result exeNonQuery(String sql,Object...params){
        Connection con = null;
        PreparedStatement pst = null;
        try {
            con = getCon();
            pst = getPst(con,sql,params);
            return Result.succeed(pst.executeUpdate());
        } catch (SQLException e) {
            return Result.fail();
        }finally {
            close(pst,con);
        }
    }

    public Result exeQuery(String sql,Object...params){
        Connection con =null;
        PreparedStatement pst = null;
        ResultSet rst = null;
        try {
            con = getCon();
            pst = getPst(con,sql,params);
            rst = pst.executeQuery();
            List<List<String>> data = new ArrayList<>();
            if (null!=rst&&rst.next()){
                final int CC = rst.getMetaData().getColumnCount();
                do{
                    List<String> row = new ArrayList<>(CC);
                    for (int i = 1; i <=CC ; i++) {
                        row.add(rst.getObject(i).toString());
                    }
                    data.add(row);
                }while (rst.next());
            }
            return Result.succeed(data);
        }catch (Exception e){
            return Result.fail();
        }finally {
            close(rst,pst,con);
        }
    }
}

四、结果集类

  • 使用泛型存结果,统一输出格式
package cn.kb10.jdbc2;

public final class Result<T> {
    //统一格式的类
    private boolean err;
    private T data;

    //方法集泛型
    public static <T> Result succeed(T data){
        return new Result(false,data);
    }

    public static Result fail(){
        return new Result(true,null);
    }

    private Result(boolean err, T data) {
        this.err = err;
        this.data = data;
    }

    public boolean isErr() {
        return err;
    }

    public T getData() {
        return data;
    }
}

五、实现JDBC操作数据库

11、这里就不多说了,直接贴查询和增删改的测试代码,就是new一个对象,然后输出结果即可。

目录JDBC基础入门概念本质JDBC的7个步骤JDBC入门示例代码JDBC基础入门概念JDBC(JavaDataBaseConnectivity,java数据库连接)是一种用于执行SQL语句的Jav
1JDBC是Java的API,各数据库厂商负责实现,我们只要装上对应的驱动,从而操作JDBC接口就能使用不同的数据库,这样就避免了使用不同数据库就要学习不同数据库的方法2Connection:与数据
<?xmlversion10encodingUTF8?><projectxmlnshttp://mavenapacheorg/POM/400xmlns:xsihttp://wwww3
1,首先在自己新建的项目文本框中输入WebProject的名称,然后单击下一步。2,继续单击下一步3,把Generatewebxmldeploymentdescriptor复选框勾上。4,单击Fini
javajdbc连接和使用jdbc导入驱动//jar是已经打包好的class文件集,可以引用到其他工程中//BuildPath中addexternaljars导入连接JDBC1加载驱动Classfro
1前提是MyEclipse已经能正常开发Java工程2安装MySQL个人使用的是版本是mysql5022win32zip网址:http://wwwmysqlcom/downloads/mysql/do
环境首先确保安装了jdk和maven,我个人使用的是openjdk11和maven3,由于本人非常建议使用python版本的ycsb,建议安装python。ubuntu1804下可以使用apt安装:a
JDBC连接MySQLJDBC连接MySQL加载及注册JDBC驱动程序ClassforName("commysqljdbcDriver");ClassforName("commysqljdbcDri
JDBC操作MySQL数据库案例1importjavasqlConnection;2importjavasqlDriverManager;3importjavasqlPreparedStatemen
、事务概述1.什么是事务一件事情有n个组成单元要不这n个组成单元同时成功要不n个单元就同时失败就是将n个组成单元放到一个事务中2.mysql的事务默认的事务:一条sql语句就是一个事务默认就开启事务