后端开发——JDBC的学习（二）

news/2024/5/18 21:49:36 标签: java, 后端, idea, 开发语言, mysql, JDBC

上篇对JDBC基础使用进行了简单的总结，了解了JDBC的基本流程，接下来对prepareStatement的使用、增删改查的练习、主键回显以及插入操作的优化进行总结，以下代码可以直接复制到idea中运行，便于理解和练习；

代码一：prepareStatement的使用：

java">import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.Scanner;
//TODO prepareStatement（载具）的使用：以后不用statement载具；
/*与statement有点不同：
1.首先编写sql语句 不包含动态值部分的语句，动态值部分使用占位符？替代，注意：？只能替代动态值；
2.创建preparationStatement，并传入动态值
3.动态值 占位符 赋值？
4.发送sql语句，并获取返回结果
 */
public class data_test3 {
    public static void main(String[] args)throws Exception {
        Scanner scan=new Scanner(System.in);
        System.out.println("请输入department_id");
        int id1=scan.nextInt();
        System.out.println("请输入location_id");
        int id2=scan.nextInt();
        //1.创建驱动：
        Class.forName("com.mysql.jdbc.Driver");
        //2.创建链接：
        Connection connection = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/atguigudb", "root", "dir99");
        //3.编写sql语句 不包含动态值部分的语句，动态值部分使用占位符？替代，注意：？只能替代动态值；
        String sql="select * from departments where department_id=? and location_id=?";
        //4.创建预编译statement并设置sql语句结果 注意这里就要传入sql语句：
        PreparedStatement preparedStatement = connection.prepareStatement(sql);
        //5.单独的占位符进行赋值：这个方法第一个参数：index，占位符的位置，从左向右，从一开始；第二个参数：Object，占位符的值；
        preparedStatement.setObject(1,id1);
        preparedStatement.setObject(2,id2);
        //6.发送sql语句并获取返回结果：查询调用Query，非查询调用Update；此时不用再传sql语句了，因为上面已经传好了
        ResultSet resultSet = preparedStatement.executeQuery();
        //7.结果解析：也就是移动一次，如果有数据说明登录成功；
        if(resultSet.next()){
            System.out.println("登陆成功！");
        }else{
            System.out.println("登陆失败！");
        }
        resultSet.close();
        preparedStatement.close();
        connection.close();
    }
}

代码二： 增删改查的练习：

java">import org.junit.Test;
import java.sql.*;
import java.util.*;
//TODO 增删改查的使用：注意查询方法！

public class data_test4 {
    public static void main(String[] args) {

    }
    @Test
    public void testInsert() throws Exception {
        //对于job_grades表：添加A 1500 3000这条数据
        //1.创建驱动：
        Class.forName("com.mysql.jdbc.Driver");
        //2.创建连接：
        Connection connection = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/atguigudb","root","dir99");
        //3.编写sql语句以及创建prepareStatement
        String sql="insert into job_grades values(?,?,?)";
        PreparedStatement preparedStatement = connection.prepareStatement(sql);
        preparedStatement.setObject(1,"A");
        preparedStatement.setObject(2,1500);
        preparedStatement.setObject(3,3000);
        //发送sql语句：
        int i = preparedStatement.executeUpdate();
        if(i>0){
            System.out.println("数据插入成功！");
        }else{
            System.out.println("数据插入失败！");
        }
        preparedStatement.close();
        connection.close();

    }
    @Test
    public void testDelete()throws Exception{
        Class.forName("com.mysql.jdbc.Driver");
        Connection connection = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/atguigudb", "root", "dir99");
        String sql="delete from job_grades where grade_level=?";
        PreparedStatement preparedStatement = connection.prepareStatement(sql);
        preparedStatement.setObject(1,"F");
        int i = preparedStatement.executeUpdate();
        if(i>0){
            System.out.println("删除成功！");
        }else{
            System.out.println("删除失败！");
        }
        preparedStatement.close();
        connection.close();

    }
    @Test
    public void testUpdate()throws Exception{
        //对于job_grades表：将刚添加的A 1500 3000这条数据中3000改为9999；
        Class.forName("com.mysql.jdbc.Driver");
        Connection connection = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/atguigudb", "root", "dir99");
        String sql="update job_grades set highest_sal=? where lowest_sal=?";
        PreparedStatement preparedStatement = connection.prepareStatement(sql);
        preparedStatement.setObject(1,9999);
        preparedStatement.setObject(2,1500);
        int i = preparedStatement.executeUpdate();
        if(i>0){
            System.out.println("更新成功！");
        }else{
            System.out.println("更新失败！");
        }
        preparedStatement.close();
        connection.close();


    }
    @Test
    //注意此处查询想查询所有数据，然后将数据放入到List<Map>list集合中：
    //可知查询结果是一行一行的，返回的是resultSet,然后将一行存入到map中，map(key=列名，value=列的内容)-》List<Map> list;
    //实现思路：遍历每一行数据，一行对应一个map，获取一行的列名和对应的列的属性，装配即可；然后将map装到一个集合当中就完成了；
    public void testSearch()throws Exception{
        Class.forName("com.mysql.jdbc.Driver");
        Connection connection = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/atguigudb", "root", "dir99");
        String sql="select * from job_grades";
        PreparedStatement preparedStatement = connection.prepareStatement(sql);
        ResultSet resultSet = preparedStatement.executeQuery();
        //TODO 获取列的信息对象:避免手动获取每一个列的数据,metaData装的是当前结果集中列的信息对象（它可以根据下角标获取列的名称，也可以获取列的数量）；
        ResultSetMetaData metaData = resultSet.getMetaData();
        //列的数量：有了它以后就可以水平遍历列：
        int columnCount = metaData.getColumnCount();
        List<Map> list=new ArrayList<>();
        while(resultSet.next()){
            //一行对应一个map；
            Map map=new HashMap();
            //下面这种方式纯手动提取，如果列的个数更多会非常麻烦并且换一个表就得重新写，效率很低；
//            map.put("gradelevel",resultSet.getString(1));
//            map.put("lowestsal",resultSet.getInt(2));
//            map.put("highestsal",resultSet.getInt(3));
            //新的方法读取每一个属性的数据，自动遍历列，注意要从一开始，和数据区分开
            for(int i=1;i<=columnCount;i++){
                //获取对应列的属性值：
                Object value = resultSet.getObject(i);
                //要是想加入map中，需要传入key和value，value已经有了，但是key：列名还没有：获取列的名称：这个方法可以获取列的别名，getcolumnname方法会获取列的名称，万一要是起了别名，就找不到了；
                String columnLabel = metaData.getColumnLabel(i);
                map.put(columnLabel,value);
            }
            list.add(map);
        }
        System.out.println(list);
        for(Object data:list){
            System.out.println(data);
        }
        resultSet.close();
        preparedStatement.close();
        connection.close();
    }
}

代码三：主键回显（获取主键的值）

java">import java.sql.*;
//主键回显：也就是一个从表关联一个主表中的主键，这个主键是自增长的，然后在向从表插入数据的时候，不知道主键的值，因此需要主键回显，得到主键的值；
public class data_test5 {
    public static void main(String[] args) throws Exception {
        returnPrimarykey();
    }
    /*所用的数据库：
CREATE TABLE t_user(
id INT PRIMARY KEY AUTO_INCREMENT COMMENT'用户主键',
`account` VARCHAR(20) NOT NULL UNIQUE COMMENT '账号',
`password` VARCHAR(64)NOT NULL COMMENT'密码',
nickname VARCHAR(20) NOT NULL COMMENT'昵称');
     */
    //TODO 向表中插入一条数据，并且获得数据库自增长主键
    //TODO 总结：在创建statement的时候，需要传入第二个参数，带回自增长的主键;获取带回来的结果集对象，一行一列，获取对应的数据即可；就得到了本次插入数据的主键id值是多少了；
    public static void returnPrimarykey()throws Exception{
        Class.forName("com.mysql.cj.jdbc.Driver");
        Connection connection = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/atguigudb","root","dir99");
        String sql="insert into t_user(account,password,nickname)values(?,?,?)";
        PreparedStatement preparedStatement = connection.prepareStatement(sql, Statement.RETURN_GENERATED_KEYS);
        preparedStatement.setObject(1,"test1");
        preparedStatement.setObject(2,"123456");
        preparedStatement.setObject(3,"hello");
        int i = preparedStatement.executeUpdate();
        if(i>0){
            System.out.println("插入成功！");
            //获取带回的主键的结果集对象，一行一列  id=值
            ResultSet generatedKeys = preparedStatement.getGeneratedKeys();
            //向下移动一行，移动一下光标，此时位于第一行
            generatedKeys.next();
            //取第一列：
            int id = generatedKeys.getInt(1);
            System.out.println("主键id的值为："+id);

        }else{
            System.out.println("插入失败！");
        }
        preparedStatement.close();
        connection.close();
    }
}

代码四：插入数据操作的优化（批量插入）

java">import org.junit.Test;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;

//TODO 插入优化操作：批量插入;
public class data_test6 {
    public static void main(String[] args)throws Exception {
        //insert_test();
        insert_test1();
    }
    //优化之前：
    @Test
    public static void insert_test()throws Exception{
        Class.forName("com.mysql.cj.jdbc.Driver");
        Connection connection = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/atguigudb","root","dir99");
        String sql="insert into t_user(account,password,nickname)values(?,?,?)";
        PreparedStatement preparedStatement = connection.prepareStatement(sql);
        long start=System.currentTimeMillis();
        for(int i=1;i<=1000;i++){
            preparedStatement.setObject(1,"root"+i);
            preparedStatement.setObject(2,"123"+i);
            preparedStatement.setObject(3,"hello"+i);
            preparedStatement.executeUpdate();
        }
        long end=System.currentTimeMillis();
        System.out.println("执行一千次消耗的时间ms："+(end-start));
    }
    //优化后：使用批量插入：
    //TODO 首先在建立连接路径上数据库后面需要添加一个参数，然后需要使用addBatch将数据追加到values的后面，然后最后执行；
    public static void insert_test1()throws Exception{
        Class.forName("com.mysql.cj.jdbc.Driver");
        //TODO 注意此处数据库后面需要添加一个参数：
        Connection connection = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/atguigudb?rewriteBatchedStatement=true","root","dir99");
        String sql="insert into t_user(account,password,nickname)values(?,?,?)";
        PreparedStatement preparedStatement = connection.prepareStatement(sql);
        long start=System.currentTimeMillis();
        for(int i=1;i<=1000;i++){
            preparedStatement.setObject(1,"root_test"+i);
            preparedStatement.setObject(2,"1234a"+i);
            preparedStatement.setObject(3,"helloa"+i);
            //TODO 下面这段代码是将上面的数据添加到values的后面，就是说sql语句values后面可以跟多个括号，一次插入多条数据；
            preparedStatement.addBatch();
        }
        //TODO 执行批量操作：
        preparedStatement.executeBatch();
        long end=System.currentTimeMillis();
        System.out.println("执行一千次消耗的时间ms："+(end-start));

    }
}


http://www.niftyadmin.cn/n/5307898.html

相关文章

考研复试英语口语问答举例第二弹

考研复试英语口语问答举例第二弹

考研复试英语口语问答举例第二弹 文章目录 考研复试英语口语问答举例第二弹Question &#xff1a;介绍你的读研兴趣与动机Answer11&#xff1a;&#xff08;自动化控制方向&#xff09;Answer12&#xff1a;&#xff08;集成电路方向&#xff09;Answer13&#xff1a;&#xff…
阅读更多...
马克思主义基本原理 | 第二章 世界的物质性及发展规律 | 期末重点整理

马克思主义基本原理 | 第二章 世界的物质性及发展规律 | 期末重点整理

目录 2.1世界多样性和物质统一性 2.1.1哲学基本问题 2.1.2辩证法和形而上学 2.1.3马克思主义的物质范畴及其理论意义 2.2事物的联系和发展 2.2.1联系的内涵和特点 2.2.2事物普遍联系原理的方法论意义 2.2.3发展的实质 2.2.4唯物辩证法的实质和核心 2.2.5量变质变规律…
阅读更多...
练习-双指针的使用

练习-双指针的使用

目录 前言一、双指针遍历数组1.1 题目一 总结 前言 最近感觉有点疲倦&#xff0c;学习的时间不多&#xff0c;但不想中断写博客的连续&#xff0c;本篇文章就记录一下在写c语言练习过程中利用双指针解题。 一、双指针遍历数组 1.1 题目一 题目&#xff1a;将一个数组中的奇数…
阅读更多...
第14课 利用openCV快速数豆豆

第14课 利用openCV快速数豆豆

除了检测运动&#xff0c;openCV还能做许多有趣且实用的事情。其实openCV和FFmpeg一样都是宝藏开源项目&#xff0c;貌似简单的几行代码功能实现背后其实是复杂的算法在支撑。有志于深入学习的同学可以在入门后进一步研究算法的实现&#xff0c;一定会受益匪浅。 这节课&#…
阅读更多...
K8S--- volumesvolumeMount

K8S--- volumesvolumeMount

一、Volume 简介 在容器当中的磁盘文件（on-disk file )是短暂的（ephemeral）,这会对重要的应用程序或者数据产生一些问题。当容器崩溃或停止时，会出现一个问题，即容器状态不会被保存，因此在容器生命周期内被创建或者修改的文件都将丢失。在容器崩溃期间，kubelet会以干净状…
阅读更多...
与CSDN相识的第一年

与CSDN相识的第一年

&#x1d649;&#x1d65e;&#x1d658;&#x1d65a;!!&#x1f44f;&#x1f3fb;‧✧̣̥̇‧✦&#x1f44f;&#x1f3fb;‧✧̣̥̇‧✦ &#x1f44f;&#x1f3fb;‧✧̣̥̇:Solitary-walk ⸝⋆ ━━━┓ - 个性标签 - &#xff1a;来于“云”的“羽球人”。…
阅读更多...
由浅入深理解C#中的事件

由浅入深理解C#中的事件

目录 本文较长&#xff0c;给大家提供了目录&#xff0c;可以直接看自己感兴趣的部分。 前言有关事件的概念示例​ 简单示例​ 标准 .NET 事件模式​ 使用泛型版本的标准 .NET 事件模式​ 补充总结 参考前言 前面介绍了C#中的委托&#xff0c;事件的很多部分都与委托…
阅读更多...
Linux第17步_安装SSH服务

Linux第17步_安装SSH服务

secure shell protocol简称SSH。 目的&#xff1a;在进行数据传输之前&#xff0c;SSH先对联级数据包通过加密技术进行加密处理&#xff0c;然后再进行数据传输&#xff0c;确保数据传输安全。 1、在安装前&#xff0c;要检查虚拟机可以上网&#xff0c;否则可能会导致安装失…
阅读更多...
最新文章

Copyright @ 2022~2023