手动实现数据库修改(添加、修改、删除)操作【单行】

手动实现对数据库中【单行】数据的修改(添加、修改、删除)操作(以Customers表为例)

 Customers表

添加操作：

/***
     * @Description    向customer表中添加一条记录
     * @author XiaoFeng  
     * @date 2020年8月21日下午12:45:09
     */
    @Test
    public void testInstance() {
        Connection conn = null;
        PreparedStatement ps = null;
        try {
            // 一. 建立与数据库的连接
            // 1. 加载资源
//        InputStream is = MySqlTest.class.getClassLoader().getResourceAsStream("jdbc.properties") ;
            InputStream is = ClassLoader.getSystemClassLoader().getResourceAsStream("jdbc.properties");
            Properties pros = new Properties();
            pros.load(is);
            // 2. 读取资源
            String user = pros.getProperty("user");
            String password = pros.getProperty("password");
            String url = pros.getProperty("url");
            String driver = pros.getProperty("driverClass");
            // 3. 加载驱动
            Class.forName(driver);
            // 4. 获取数据库连接
            conn = DriverManager.getConnection(url, user, password);
            // 二. 操作数据库
            // 1. 预编译sql语句，返回PreparedStatement实例对象
            String sql = "insert into customers(id,name,email,birth) values(?,?,?,?) ";
            ps = conn.prepareStatement(sql);
            // 2. 填充占位符
            ps.setObject(1, 20);
            ps.setObject(2, "钢铁侠");
            ps.setObject(3, "911.@usa.cn");
            ps.setObject(4, "1990-09-01");
            // 3. 执行操作
            ps.execute();
            System.out.println("数据填充完成！");
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            // 三. 关闭资源
            if (ps != null) {
                try {
                    ps.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if (conn != null) {
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
    }

修改操作：

/***
     * 
     * @Description 修改customer表中的一个记录
     * @author XiaoFeng
     * @throws Exception
     * @date 2020年8月21日下午12:47:00
     */
    @Test
    public void testUpdate() {
        Connection conn = null;
        PreparedStatement ps = null;
        try {
            // 与数据库建立 连接
            // 加载资源
            InputStream is = ClassLoader.getSystemClassLoader().getResourceAsStream("jdbc.properties");
            Properties pros = new Properties();
            pros.load(is);
            // 读取资源
            String user = pros.getProperty("user");
            String password = pros.getProperty("password");
            String url = pros.getProperty("url");
            String driver = pros.getProperty("driverClass");
            // 加载数据库驱动
            Class.forName(driver);
            // 获取数据库连接
            conn = DriverManager.getConnection(url, user, password);

            // 操作数据库
            // 预编译SQL语句，返回PreparedStatement实例对象
            String sql = "update customers set name = ? where id = ?";
            ps = conn.prepareStatement(sql);
            // 填充占位符
            ps.setObject(1, "钢铁侠2.0");
            ps.setObject(2, 20);
            // 执行语句
            ps.execute();
            System.out.println("修改数据成功");
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            // 关闭资源
            if (ps != null) {
                try {
                    ps.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if (conn != null) {
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
    }

总结：实现对数据库中【单行】数据的修改(添加、修改、删除)统一操作

/***
     * 
     * @Description 对数据库增删改的通用操作
     * @author XiaoFeng
     * @throws Exception
     * @date 2020年8月21日下午1:04:57
     */
//    与可变形参的长度要与sql中占位符的个数相同
    public void Update(String sql, Object... args) {
        
        Connection conn = null;
        PreparedStatement ps = null;
        try {
            // 建立与数据库的连接
                // 加载资源
            InputStream is = ClassLoader.getSystemClassLoader().getResourceAsStream("jdbc.properties");
            Properties pros = new Properties();
            pros.load(is);
                // 获取资源
            String user = pros.getProperty("user");
            String password = pros.getProperty("password");
            String url = pros.getProperty("url");
            String driver = pros.getProperty("driverClass");
                // 加载数据库驱动
            Class.forName(driver);
                // 获取数据库连接
            conn = DriverManager.getConnection(url, user, password);
            // 操作数据库
                // 预编译SQL语句，返回PreparedStatement实例对象
            ps = conn.prepareStatement(sql);
                // 填充占位符
            for (int i = 0; i < args.length; i++) {
                ps.setObject(i + 1, args[i]);
            }
                // 执行操作
            ps.execute();
            System.out.println("操作执行完成！");
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            // 关闭资源
            if (ps != null) {
                try {
                    ps.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if (conn != null) {
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
    }

测试代码：

@Test
    public void CreatrTest() {
//         测试添加操作
        String sql = "insert into customers(id,name,email,birth) values(?,?,?,?)";
        Update(sql, 21, "美国队长", "MGDZ@test.com", "1850-07-01");
    }

    @Test
    public void deleteTest() {
//         测试删除操作
        String sql = "delete from customers where id = ?";
        Update(sql, 21);
    }

    @Test
    public void UpdateTest() {
//         测试修改操作
        String sql = "update customers set name = ? where id = ?";
        Update(sql, "钢铁侠3.0", 20);
    }