java中JDBC增删改查操作详解

 更新时间:2021年12月16日 09:15:40   作者:Michelhjx  
大家好,本篇文章主要讲的是java中JDBC增删改查操作详解,感兴趣的同学赶快来看一看吧,对你有帮助的话记得收藏一下,方便下次浏览

前言

        在上一篇博客我们介绍了JDBC的概念以及连接数据库的五种方式JDBC概述及数据库连接方式(数据库连接方式推荐使用第五种),那么我们既然连接上数据库了,那就要对数据进行操作了,那么这一篇我们就来介绍常规的增删改 查操作。

     

我们先看一遍步骤:    

这里不推荐使用Statement,两个原因:

                1.存在拼串操作,繁琐。

                2.存在sql注入问题。

        那我们使用谁来代替Statement呢?

一、增删改操作

        操作前,我们先解决上面的问题,我们使用PreparedStatement来代替Statement。

1.1 PreparedStatement介绍

可以通过调用 Connection 对象的 preparedStatement(String sql) 方法获取 PreparedStatement 对象

PreparedStatement 接口是 Statement 的子接口,它表示一条预编译过的 SQL 语句

PreparedStatement 对象所代表的 SQL 语句中的参数用问号(?)来表示,调用 PreparedStatement 对象的 setXxx() 方法来设置这些参数. setXxx() 方法有两个参数,第一个参数是要设置的 SQL 语句中的参数的索引(从 1 开始),第二个是设置的 SQL 语句中的参数的值

 优点:

解决字符串拼串问题,防止sql注入提高性能       

 1.2 增删改操作

        这里给出一个针对不同表的通用增删改操作,拿着直接用就可以了。

//通用增删改操作
    public boolean updateInfo(String sql,Object...args){
        Connection conn = null;
        PreparedStatement ps = null;
        boolean b = true;
        try {
            //1.建立连接
            conn = JDBCUtils.getConnection();
            //2.预编译sql语句
            ps = conn.prepareStatement(sql);
            //3.填充占位符
            for (int i = 0; i <args.length ; i++) {
                ps.setObject(i+1,args[i]);
            }
            //4.执行操作
            b = ps.execute();
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            //5.关闭资源
            JDBCUtils.close(conn,ps);
        }
        return b;
    }

         是不是复制使用会报错,这是因为博主把数据库连接和关闭资源也封装成了一个类JDBCUtils

        下面给出这个类的具体代码:

        配置文件就自己写吧,毕竟每个人的数据库都不一样。以及该导入的包自己动动手就行了。

public class JDBCUtils {
    //连接
    public static Connection getConnection(){
        Connection conn = null;
        try {
            //1.加载配置文件
            InputStream is = ClassLoader.getSystemClassLoader().getResourceAsStream("jdbc.properties");
            Properties prop = new Properties();
            prop.load(is);
 
            //2.读取配置文件
            String user = prop.getProperty("user");
            String password = prop.getProperty("password");
            String url = prop.getProperty("url");
            String driverClass = prop.getProperty("driverClass");
 
            //3.加载驱动
            Class.forName(driverClass);
 
            //4.建立连接
            conn = DriverManager.getConnection(url, user, password);
        } catch (Exception e) {
            e.printStackTrace();
        }
 
 
        return conn;
    }
 
    //关闭
    public static void close(Connection conn, PreparedStatement ps){
        try {
            if (conn != null){
                conn.close();
            }
            if (ps != null){
                ps.close();
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
    //关闭带resultset
    public static void close(Connection conn, PreparedStatement ps , ResultSet rs){
        try {
            if (conn != null){
                conn.close();
            }
            if (ps != null){
                ps.close();
            }
            if (rs != null){
                rs.close();
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

  1.3 测试

        我们来测试一下上面的代码

        这里有一张order表,里面有初始数据:

        ​​​​​​​        

         然后我们通过上面提供的方法给他增加一条数据:

public class Test {
    public static void main(String[] args) {
        Operation operation = new Operation();
        String insertSql = "INSERT INTO `order`(order_id,order_name,order_date) VALUES (?,?,?)";
        boolean b = operation.updateInfo(insertSql, 3, "CC", new Date(12312132));
        if (!b){
            System.out.println("操作成功!");
        }else {
            System.out.println("操作失败!");
        }
    }
}

        控制台打印输出:

        

         那么是不是已经插入成功了呢,我们去数据库中看一下:

          我们 SELECT * FROM `order`;

        

        看来我们确实成功了!所以我们给出的方法还是没有问题。

二、查操作

        接下来我们就是查操作了。

2.1 通用对不同表进行一条数据查询操作

public  <T> T doQuery(Class<T> clazz,String sql,Object...args) {
        Connection conn = null;
        PreparedStatement ps = null;
        ResultSet rs = null;
        try {
            //1.建立连接
            conn = JDBCUtils.getConnection();
            //2.预编译sql语句
            ps = conn.prepareStatement(sql);
            //3.填充占位符
            for (int i = 0; i <args.length ; i++) {
                ps.setObject(i+1,args[i]);
            }
            //4.得到结果集ResultSet
            rs = ps.executeQuery();
            //5.得到结果集元数据
            ResultSetMetaData rsdm = rs.getMetaData();
 
            //6.通过rs得到列值,rsdm得到列名和列数
            //得到列数
            int columnCount = rsdm.getColumnCount();
            if (rs.next()){
                T t = clazz.getDeclaredConstructor().newInstance();
                for (int i = 0; i <columnCount ; i++) {
                    //得到列值
                    Object columnvalue = rs.getObject(i + 1);
                    //得到列的别名
                    String columnLabel = rsdm.getColumnLabel(i + 1);
 
                    //通过反射给对象赋值
                    Field field = clazz.getDeclaredField(columnLabel);
                    //暴力反射
                    field.setAccessible(true);
                    field.set(t,columnvalue);
                }
                return t;
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            //关闭资源
            JDBCUtils.close(conn,ps,rs);
        }
        return null;
    }

        老样子,测试!

public class Test {
    public static void main(String[] args) {
        Operation operation = new Operation();
        String sql = "SELECT order_id orderId,order_name orderName,order_date orderDate FROM `order` WHERE order_id = ?;";
        Order order = operation.doQuery(Order.class, sql, 2);
        System.out.println(order);
    }
}

 控制台输出:

        

2.2 通用对不同表进行多条数据查询操作

public <T> List doQueryMore(Class<T> clazz,String sql,Object...args){
        Connection conn = null;
        PreparedStatement ps = null;
        ResultSet rs = null;
        try {
            //1.建立连接
            conn = JDBCUtils.getConnection();
            //2.预编译sql语句
            ps = conn.prepareStatement(sql);
            //3.填充占位符
            for (int i = 0; i <args.length ; i++) {
                ps.setObject(i+1,args[i]);
            }
            //4.得到结果集ResultSet
            rs = ps.executeQuery();
            //5.得到结果集元数据
            ResultSetMetaData rsdm = rs.getMetaData();
 
            //6.通过rs得到列值,rsdm得到列名和列数
            //得到列数
            int columnCount = rsdm.getColumnCount();
            //创建集合
            ArrayList<T> list = new ArrayList<>();
            while (rs.next()){
                T t = clazz.getDeclaredConstructor().newInstance();
                for (int i = 0; i <columnCount ; i++) {
                    //得到列值
                    Object columnvalue = rs.getObject(i + 1);
                    //得到列的别名
                    String columnLabel = rsdm.getColumnLabel(i + 1);
 
                    //通过反射给对象赋值
                    Field field = clazz.getDeclaredField(columnLabel);
                    //暴力反射
                    field.setAccessible(true);
                    field.set(t,columnvalue);
                }
                list.add(t);
            }
            return list;
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            //关闭资源
            JDBCUtils.close(conn,ps,rs);
        }
        return null;
    }

         这一个测试就交给各位吧!

总结

到此这篇关于java中JDBC增删改查操作详解的文章就介绍到这了,更多相关java JDBC增删改查内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • Java设计模式中组合模式应用详解

    Java设计模式中组合模式应用详解

    组合模式,又叫部分整体模式,它创建了对象组的数据结构组合模式使得用户对单个对象和组合对象的访问具有一致性。本文将通过示例为大家详细介绍一下组合模式,需要的可以参考一下
    2022-11-11
  • JDK8中的HashMap初始化和扩容机制详解

    JDK8中的HashMap初始化和扩容机制详解

    这篇文章主要介绍了JDK8中的HashMap初始化和扩容机制,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2021-06-06
  • 解决springboot与springcloud版本兼容问题(附版本兼容表)

    解决springboot与springcloud版本兼容问题(附版本兼容表)

    在基于spring boot搭建spring cloud时,创建eureka后启动服务发生报错,本文给大家介绍了解决springboot与springcloud版本兼容问题的几种方案,需要的朋友可以参考下
    2024-02-02
  • Java JVM调优五大技能详解

    Java JVM调优五大技能详解

    这篇文章主要为大家介绍了JVM调优的五大技能,具有一定的参考价值,感兴趣的小伙伴们可以参考一下,希望能够给你带来帮助
    2021-11-11
  • SpringBoot使用Validator进行参数校验实战教程(自定义校验,分组校验)

    SpringBoot使用Validator进行参数校验实战教程(自定义校验,分组校验)

    这篇文章主要介绍了SpringBoot使用Validator进行参数校验(自定义校验,分组校验)的实战教程,本文通过示例代码给大家介绍的非常详细,需要的朋友参考下吧
    2023-07-07
  • java利用mybatis拦截器统计sql执行时间示例

    java利用mybatis拦截器统计sql执行时间示例

    这篇文章主要介绍了java利用mybatis拦截器统计sql执行时间示例,该拦截器拦截mybatis的query和update操作,能统计sql执行时间
    2014-03-03
  • SpringBoot项目使用slf4j的MDC日志打点功能(最新推荐)

    SpringBoot项目使用slf4j的MDC日志打点功能(最新推荐)

    这篇文章主要介绍了SpringBoot项目使用slf4j的MDC日志打点功能,本文通过示例代码给大家介绍非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2023-06-06
  • 解析java中volatile关键字

    解析java中volatile关键字

    这篇文章主要为大家解析了java中volatile关键字,经常有人把volatile关键字和synchronized或者lock混淆,本文就为大家好好区分,感兴趣的小伙伴们可以参考一下
    2016-01-01
  • 实例解析Java的Jackson库中的数据绑定

    实例解析Java的Jackson库中的数据绑定

    这篇文章主要介绍了Java的Jackson库中的数据绑定,这里分为通常的简单数据绑定与全数据绑定两种情况来讲,需要的朋友可以参考下
    2016-01-01
  • Springboot AOP开发教程

    Springboot AOP开发教程

    AOP是OOP的延续,是软件开发中的一个热点,也是Spring框架中的一个重要内容,是函数式编程的一种衍生范型,本文给大家介绍Springboot AOP开发教程,感兴趣的朋友跟随小编一起看看吧
    2024-03-03

最新评论