【MySQL】JDBC编程

欢迎关注个人主页：逸狼

---

创造不易，可以点点赞吗~

如有错误，欢迎指出~

---

---

代码连接数据库的 前期准备

针对数据库的操作,实际工作中 很少会直接通过 命令行/图形化 客户端来操作数据库,更多是通过代码(C++,Java,Python,Go.....)操作数据库,前提数据库要提供一组API(Application Programming Interface 应用程序编程接口,在库中的类/方法/函数就可以称为API)供其他程序来使用

每个数据库的api都是自成一套体系,Java自身指定了一套API,其他数据库都要把自己的API转换成和Java这一套兼容的API(即JDBC),对于Java程序员,只需要学习一套api就可以应对各种数据库了

mysql官方提供了一个mysql-connector第三方库 将MySQL原生的C的API转换成 兼容JDBC的Java的API

mysql-connector 是第三方库,需要自己下载,推荐取maven中央仓库下载

以下是下载步骤:

如果mysql 服务器是8系列,connector 也必须使用8版本(5版本同理)

下载好jar包 ,在idea里创建一个项目,拷贝到自己创建的一个目录(这里演示的是'lib' ),右键这个目录,选择 add as library(告诉idea,这个lib目录是一个'库'目录),添加完 '库'后,此时idea就能自动分析出jar包里的内容

通过代码使用JDBC的API

下面通过演示 用代码操作数据库 并 插入数据的效果

创建数据源对象

由于DataSource是一个Interface,不能new出来,需要实现这个接口的子类(MysqlDataSource())

        //1.创建数据源对象
        DataSource dataSource =new MysqlDataSource();

        //给数据源对象 设置必要的属性
        ((MysqlDataSource) dataSource).setUrl("jdbc:mysql://127.0.0.1:3306/test1?characterEncoding=utf8&useSSL=false");
        ((MysqlDataSource) dataSource).setUser("root");
        ((MysqlDataSource) dataSource).setPassword("111111");

给数据源对象设置必要属性

setUrl

设置 数据库服务器的 位置

**URL称为 "唯一资源定位符" **用来描述一个 网络上的资源的位置,数据库也可以理解为一种网络资源

代码中setUrl里的: jdbc:mysql://127.0.0.1:3306/test1characterEncoding=utf8&usesSL=false(不用记,知道含义就行)

setUser

设置 访问服务器的账户

**root **是 mysql自带用户,管理员用户,权限是最高的

setPassword

**设置 访问服务的密码 ** (你安装数据库时 设置的密码)

建立网络连接

        //2.和数据服务器建立网络连接
        dataSource.getConnection();
        Connection connection =dataSource.getConnection();
        System.out.println(connection);

构造sql语句

        //3.程序构造sql语句
        String sql ="insert into student values(1,'张三')";
        PreparedStatement statement = connection.prepareStatement(sql);

发送到服务器 执行

        //把sql语句发送到服务器上,让服务器执行
        int n=statement.executeUpdate();//n表示执行的语句数量
        System.out.println(n);//查看要几行被影响了

释放资源

释放资源的顺序要和创建资源的顺序 相反

        //5.释放上述资源
        statement.close();
        connection.close();

完整代码 插入数据

update/ delete 代码完全一样,只是把string sql里的内容换了

    public static void main(String[] args) throws SQLException {
        //1.创建数据源对象
        DataSource dataSource =new MysqlDataSource();

        //给数据源对象 设置必要的属性
        ((MysqlDataSource) dataSource).setUrl("jdbc:mysql://127.0.0.1:3306/test1?characterEncoding=utf8&useSSL=false");
        ((MysqlDataSource) dataSource).setUser("root");
        ((MysqlDataSource) dataSource).setPassword("111111");

        //2.和数据服务器建立网络连接
        dataSource.getConnection();
        Connection connection =dataSource.getConnection();
        System.out.println(connection);

        //3.程序构造sql语句
        String sql ="insert into student values(1,'张三')";

        //4.把sql语句发送到服务器上,让服务器执行
        PreparedStatement statement = connection.prepareStatement(sql);
        int n=statement.executeUpdate();

        //5.释放上述资源
        statement.close();
        connection.close();
    }

插入数据后,查看数据库,插入成功

用户自行输入内容

在上面完整代码中 添加两处代码

        //0.让用户输入id 和name
        Scanner scanner= new Scanner(System.in);
        System.out.println("请输入id: ");
        int id = scanner.nextInt();
        System.out.println("请输入name: ");
        String name =scanner.next();

        //3.程序构造sql语句
        String sql ="insert into student values(?,?)";
        //把sql语句发送到服务器上,让服务器执行
        PreparedStatement statement = connection.prepareStatement(sql);
        statement.setInt(1,id);//1说明替换第一个问号
        statement.setString(2,name);
        int n=statement.executeUpdate();

查询操作代码

select 操作和上面操作相比 都了个"遍历结果集合" 步骤

    //查询
    public static void main(String[] args) throws SQLException {

        //1.创建数据源对象
        DataSource dataSource =new MysqlDataSource();
        //给数据源对象 设置必要的属性
        ((MysqlDataSource) dataSource).setUrl("jdbc:mysql://127.0.0.1:3306/test1?characterEncoding=utf8&useSSL=false");
        ((MysqlDataSource) dataSource).setUser("root");
        ((MysqlDataSource) dataSource).setPassword("111111");

        //2.和数据服务器建立网络连接
        dataSource.getConnection();
        Connection connection =dataSource.getConnection();

        //3.程序构造sql语句
        String sql ="select * from student";
        PreparedStatement statement = connection.prepareStatement(sql);

        //4.执行sql
        ResultSet resultSet=statement.executeQuery();

        //5.遍历结果集合
        while(resultSet.next()){
            //循环 针对一行数据进行处理
            System.out.println(resultSet.getInt("id"));
            System.out.println(resultSet.getString("name"));
        }
        
        //6.释放上述资源
        resultSet.close();
        statement.close();
        connection.close();
    }