2022-08-18 JDBC

发布于:2023-01-12 ⋅ 阅读:(595) ⋅ 点赞:(0)

目录

JDBC

JDBC是什么?

数据的持久化:

JDBC编程需要:

1.数据库驱动:

2.url地址:

3.数据库的用户名:

4.数据库的密码:

导入jar包

使用属性配置文件的好处:

正题:执行数据库的DML语言---增删改(没有查哟)


JDBC

JDBC是什么?

JDBC指的是Java数据库连接,是一种标准Java应用编程接口,用来连接java编程和广泛的数据库

数据的持久化:

把数据永久的保存起来。主要的方式还是得存到硬盘上。 持久化的实现过程大部分是通过数据库来完成。

JDBC编程需要:

1.数据库驱动:

        所有连接数据库都要实现的最大接口:java.sql.Driver

        如何加载驱动?

        通过反射:class.forName("com.mysql.jdbc.Driver");

        mysql:com.mysql.jdbc.Driver

        oracle:oracle.jdbc.driver.OracleDriver

2.url地址:

        需要链接数据库,其实就是链接一个服务器。

        我们之前链接服务器的时候用的是IP地址+端口号,但是针对于连接数据库的话,有一个专门的协议:jdbc协议:

        jdbc协议:jdbc:mysql://主机名称(主机地址):端口号/数据库的名字

      (这是我的地址)eg:jdbc:mysql://127.0.0.1:3306/wy?useUnicode=true&characterEncoding=utf8

3.数据库的用户名:

4.数据库的密码:

导入jar包

链接数据库需要导入外部依赖,需要引入mysql的驱动(指的是引入的jar包)

jar包:点击进入官网

我这里用的是5.1.17的,这里不推荐用8.0的,因为8.0变样了,而且非常的私有化,然后还需要解放私有化,非常麻烦,最关键的是,我不会。

我们首先需要导入jar包:在项目下建立一个文件夹:lib

然后把jar包放到文件夹里,之后右键点击add a liabrary

以上的都是准备工作,我们来真正链接数据库:

获取以上的内容

String url="jdbc:mysql://127.0.0.1:3306/wy?useUnicode=true&characterEncoding=utf8";
String username="root";//你自己的用户名字
String password="root";//你自己的用户密码
//驱动的全类名
String driverName="com.mysql.jdbc.Driver";

加载驱动类:

Class clazz = Class.forName(driverName);

实例化Driver对象

Driver driver=(Driver)clazz.getDeclaredConstructor().newInstance();

注册驱动

DriverManager.registerDriver(driver);

获取链接

Connection connection=DriverManager.getConnection(url,username,password);

接下来可以用Objects的nonNull的方法来判断是否连接成功了:

System.out.println(Objects.nonNull(connection)?"数据库连接成功":"数据库连接失败");

这下步骤太麻烦,而且在代码中,不易改变,所以我们用封装+外部文件获取驱动的方式,封装一个方法:

获取JDBC连接的方法 

jdbc.properties文件:注意,是文件,读取外部的properties属性文件,用外部文件获取驱动

mysql.url=jdbc:mysql://127.0.0.1:3306/wy?useUnicode=true&characterEncoding=utf8
mysql.username=root
mysql.password=020323
mysql.driverName=com.mysql.jdbc.Driver

 方法:

public static Connection connection(){
        Properties properties = new Properties();
        Connection connection=null;
        try {
            properties.load(Test01.class.getClassLoader().getResourceAsStream("jdbc.properties"));
            String url = properties.getProperty("mysql.url");
            String driverName = properties.getProperty("mysql.driverName");
            String username = properties.getProperty("mysql.username");
            String password = properties.getProperty("mysql.password");
            Class.forName(driverName);//加载器驱动类(可以省略实例化对象和注册驱动的过程)
            connection = DriverManager.getConnection(url, username, password);
        } catch (SQLException e) {
            throw new RuntimeException(e);
        } catch (IOException e) {
            throw new RuntimeException(e);
        } catch (ClassNotFoundException e) {
            throw new RuntimeException(e);
        }
        return connection;
    }

使用属性配置文件的好处:

1.实现了代码和数据的分离,如果需要修改配置信息,直接在属性文件中修改即可。不需要深入代码

2.如果修改了配置信息,省去了编译的过程

3.符合OCP原则

正题:执行数据库的DML语言---增删改(没有查哟)

在java中有三个接口分别定义了对数据库的调用的不同的方式:

1.Statement:用来执行静态sql语句并返回它所生成的结果对象

2.PreparedStatement:预编译,可以使用此对象多次高效的执行该语句

3.CallableStatement:用来执行sql的存储过程//不学

我们每次开启数据库连接,相对应的也要关闭连接:我们也封装一个工具类:

public static void close(Connection conn, Statement statement){
        if(Objects.nonNull(statement)){
            try {
                statement.close();
            } catch (SQLException e) {
                throw new RuntimeException(e);
            }
        }
        if(Objects.nonNull(conn)){
            try {
                conn.close();
            } catch (SQLException e) {
                throw new RuntimeException(e);
            }
        }
    }

 首先建立连接、创建Statement对象

        Connection conn =null;
        Statement statement=null;
        try {
            conn = JDBCUtil.connection();
            statement = conn.createStatement();
            //增加
            String sql="INSERT INTO teacher (name) VALUES ('法外狂徒')";
//            //返回值是执行sql语句影响的行数
            //修改
//            String sql="UPDATE teacher set name='jay'";
            //删除
//            String sql="DELETE FROM teacher where name='jay'";
            int i = statement.executeUpdate(sql);
            System.out.println(i);
            System.out.println("操作成功!!!");
        } catch (SQLException e) {
            throw new RuntimeException(e);
        }finally {
            JDBCUtil.close(conn,statement);
        }

那么我们要进行查询操作该怎么做呢:

首先获取连接,获取可以执行sql语句的statement对象,定义sql,执行查询的sql,会得到一个ResultSet,ResultSet就是封装了查询结果的一个对象,遍历结果集

    @Test
    public void test01() {
        // 1.获取连接
        Connection conn = JDBCUtil.getConnection();
        Statement stmt = null;
        ResultSet rs = null;
        try {
            // 2.获取可以执行sql语句的stmt对象
            stmt = conn.createStatement();
            // 3.定义sql
            String sql = "select id tid,name tname from teacher where id = 7";
            // 4.执行查询的sql,会得到一个ResultSet
            // ResultSet就是封装了查询结果的一个对象
            rs = stmt.executeQuery(sql);
            // 5.遍历结果集ResultSet
            while(rs.next()) {
                int id = rs.getInt("tid");
                String name = rs.getString("tname");
                System.out.println("id:" + id + ",name:" + name);
            }
        } catch (SQLException e) {
            throw new RuntimeException(e);
        } finally {
            // 6.关闭资源
            JDBCUtil.close(conn,stmt,rs);
        }
    }

 关闭资源的方法:

public static void close(Connection conn, Statement stmt, ResultSet rs) {

        if(Objects.nonNull(stmt)) {
            try {
                stmt.close();
            } catch (SQLException e) {
                throw new RuntimeException(e);
            }
        }
        if(Objects.nonNull(conn)){
            try {
                conn.close();
            } catch (SQLException e) {
                throw new RuntimeException(e);
            }
        }
        if(Objects.nonNull(rs)){
            try {
                rs.close();
            } catch (SQLException e) {
                throw new RuntimeException(e);
            }
        }
    }
本文含有隐藏内容,请 开通VIP 后查看

网站公告

今日签到

点亮在社区的每一天
去签到