栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

JDBC封装增删改查方法详解

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

JDBC封装增删改查方法详解

        在数据库中对数据的操作分为增删改查,但本质上可以将其划分为两种,增删改的操作直接作用于数据,会直接影响数据,而查询操作,并不会影响数据本身,只是将数据作为返回值返回。

        那么,怎样进行封装呢?

        再进行封装之前,我们先完成准备工作:

        创建一个properties的资源文件,用于存储连接数据库的四个基本信息(用户名,

         密码,url,驱动路径),可直接放置于src路径下

        文件名:jdbc.properties

user=root
password=123456
url=jdbc:mysql://localhost:3306/school
driverClass=com.mysql.jdbc.Driver

        资源文件建立好,我们就可以进行对增删改查的封装了,文章开篇说过,我们将增删改查分为两个方法进行封装,我们先进行增删改的封装。

        1. 通过类加载获取一个输入流,参数填写我们刚刚创建的资源文件的名字,然后创建Properties的实例,通过load方法将资源文件读入内存,紧接着取出各个value。

        2. 通过Class类的forName方法将类加载驱动,参数填写从配置文件中读取到的driverClass

        3. 通过DriverManager.getConnectoin建立数据库连接

        4. 获取到数据连接以后我们使用PerpareStatement完成sql语句预编译,此处的预编译语句我们在参数中提供

        5. 由于使用PrepareStatement,所以我们需要实参sql的占位符进行填充,而sql语句在此时并不确定,所以占位符个数也就无法确定数量,所以此时我们在参数中提供可变个数形参。

        6. 执行sql语句,此时使用execute(),此方法有一个boolean类型的值,可以以此判断操作是否成功

        7. 到此处,对增删改的封装也就算差不多了,但是还有一个很重要的步骤,是什么呢?当然是资源的关闭,我们将其放置在finally块中进行,以此保证百分百关闭资源。

    public void update1(String sql, Object ...args){
        InputStream is = ClassLoader.getSystemClassLoader().getResourceAsStream("jdbc.properties");
        Connection con = null;
        PreparedStatement ps = null;
        try {
            Properties pros = new Properties();
            pros.load(is);
            String user = pros.getProperty("user");
            String password = pros.getProperty("password");
            String url = pros.getProperty("url");
            String driverClass = pros.getProperty("driverClass");
            Class.forName(driverClass);
            con = DriverManager.getConnection(url, user, password);
            ps = con.prepareStatement(sql);
            for (int i = 0; i < args.length; i++) {
                ps.setObject(i+1, args[i]);
            }
            ps.execute();
        } catch (Exception e) {
            e.printStackTrace();
        }  finally {
            try {
                if (ps != null) {
                    ps.close();
                }
            } catch (SQLException throwables) {
                throwables.printStackTrace();
            }
            try {
                if (con != null) {
                    con.close();
                }
            } catch (SQLException throwables) {
                throwables.printStackTrace();
            }
            try {
                if (is != null) {
                    is.close();
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

        说完增删改的封装我们接着聊对查询的封装,对于查询的封装相对于增删改会麻烦一些,在进行封装之前先创建一个与数据库中表相对应的实体类,以javabean的方式创建,一定要记得创建一个空参构造器。

public class Student {
    private int id;
    private String name;
    private String sex;
    public Student(){}
    public Student(int id, String name, String sex){
        this.id = id;
        this.name = name;
        this.sex = sex;
    }

    @Override
    public String toString() {
        return "Student{" +
                "id=" + id +
                ", name='" + name + ''' +
                ", sex='" + sex + ''' +
                '}';
    }

    public int getId() {
        return id;
    }

    public void setId(int id) {
        this.id = id;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public String getSex() {
        return sex;
    }

    public void setSex(String sex) {
        this.sex = sex;
    }
}

        对查询封装的代码与增删改的代码在填充预编译sql语句的占位符那块以及之前都是相同的,所以,我就不在此赘述,直接开始接下来的步骤。

        由于我们不确定需要查找的表,以及需要创建的实体类,所以在参数处使用反射(Class clazz),在调用时传入实体类的运行时类(实体类 . class),同时,相对于查询来讲,通常不会只有一个值,所以,我们需要在开始时创建一个List集合,后续将查询到的数据赋值给实体类的实例,然后将这些实例存入到集合中作为返回值返回,我们这样理解,每一行对应着实体类的一个对象,每个字段对应实体类的属性。

        1. 填充完占位符以后执行预编译sql语句,注意,此时使用executeQuery()方法,此方法会有一个ResultSet类型的返回值(结果集),我们需要拿到这个结果集。

        2. 在进行下一步之前,请允许我多说两句, 因为我们的查询是围绕列(字段)展开的,但是我们此时无法确定具体的字段数量,怎么办呢,调用刚刚获取到的结果集的getmetaDate获取到ResultSetmetaData类型的metaData,接着调用metaData的getColumnCount()方法获取到当前获取到的结果集的列(字段)数。

        3. 使用while循环,将结果集的next()方法作为判断条件,next()方法在结果集有下一项时,会返回true,同时将指针下移。

        4. 调用运行时类clazz的newInstance()方法创建一个运行时类的对象,此方法会调用运行时类的空参构造器,若没有空参构造器会抛出异常。

        5. 调用结果集rs的getObject()方法获取到当前的value值,调用metaData的getColumnLabel()方法获取到当前的字段名,之所以用这个方法,是因为这个方法获取到的是通过查询获取到的列名,也就是说可以获取到别名。

        6. 使用运行时类的getDeclaredField()方法获取到我们刚才查询的字段所对应属性值,接着使用set方法将刚刚获取到的value设置给对应的属性值,需要注意的时,在使用set方法之前,先调setAccessible(true)。

         7. 此时数据已经赋值给实体类的实例,将实体类的实例添加到list中,循环结束后,将list作为返回值返回

        8. 关闭资源,若程序执行过程中出现异常,返回null。

public List select1(Class clazz, String sql , Object ...args){
        List list = new ArrayList<>();
        InputStream is = ClassLoader.getSystemClassLoader().getResourceAsStream("jdbc.properties");
        Properties pros = new Properties();
        Connection con = null;
        PreparedStatement ps = null;
        ResultSet rs = null;
        try {
            pros.load(is);
            String user = pros.getProperty("user");
            String password = pros.getProperty("password");
            String url = pros.getProperty("url");
            String driverClass = pros.getProperty("driverClass");
            Class.forName(driverClass);//jdbc:mysql://localhost:3306/school
            con = DriverManager.getConnection(url, user, password);
            ps = con.prepareStatement(sql);
            for (int i = 0; i < args.length; i++) {
                ps.setObject(i+1, args[i]);
            }
            rs = ps.executeQuery();
            ResultSetmetaData metaData = rs.getmetaData();
            int columnCount = metaData.getColumnCount();
            while(rs.next()){
                T t = clazz.newInstance();
                for (int i = 0; i < columnCount; i++) {
                    Object columnValue = rs.getObject(i + 1);
                    String columnLabel = metaData.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 {
            try {
                if (rs != null) {
                    rs.close();
                }
            } catch (SQLException throwables) {
                throwables.printStackTrace();
            }
            try {
                if (ps != null) {
                    ps.close();
                }
            } catch (SQLException throwables) {
                throwables.printStackTrace();
            }
            try {
                if (con != null) {
                    con.close();
                }
            } catch (SQLException throwables) {
                throwables.printStackTrace();
            }
            try {
                if (is != null) {
                    is.close();
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
        return null;
    }

        今天的分享到这就结束了,感谢您的阅读。

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/571316.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号