使用JDBC进行增删改查

前言

　　Java数据库连接，（Java Database Connectivity，简称JDBC）是Java语言中用来规范客户端程序如何来访问数据库的应用程序接口，提供了诸如查询和更新数据库中数据的方法。

　　JDBC API主要位于JDK中的java.sql包中（之后扩展的内容位于javax.sql包中），主要包括（斜体代表接口，需驱动程序提供者来具体实现）：

　　DriverManager：负责加载各种不同驱动程序（Driver），并根据不同的请求，向调用者返回相应的数据库连接（Connection）。Driver：驱动程序，会将自身加载到DriverManager中去，并处理相应的请求并返回相应的数据库连接（Connection）。Connection：数据库连接，负责与进行数据库间通讯，SQL执行以及事务处理都是在某个特定Connection环境中进行的。可以产生用以执行SQL的Statement。Statement：用以执行SQL查询和更新（针对静态SQL语句和单次执行）。PreparedStatement：用以执行包含动态参数的SQL查询和更新（在服务器端编译，允许重复执行以提高效率）。CallableStatement：用以调用数据库中的存储过程。SQLException：代表在数据库连接的建立和关闭和SQL语句的执行过程中发生了例外情况（即错误）。

准备工作

以mysql为例，需要引入数据库驱动

<!--mysql驱动坐标-->
<dependency>
      <groupId>mysql</groupId>
      <artifactId>mysql-connector-java</artifactId>
      <version>5.1.6</version>
      <scope>runtime</scope>
</dependency>

1.查询

public static void main(String[] args) throws SQLException {
        Connection connection = null;
        PreparedStatement preparedStatement = null;
        ResultSet resultSet = null;
        try {
            //1.加载数据库驱动
            Class.forName("com.mysql.jdbc.Driver");
            //2.通过驱动管理类获取数据库链接
            connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/test_jdbc","root","123456");
            //3.定义sql语句，？表示占位符
            String sql = "select * from user where username = ?";
            //4.获取预处理statement
            preparedStatement = connection.prepareStatement(sql);
            //5.设置参数，第一个参数为sql语句中参数的序号（从1开始），第二个参数为设置的参数值
            preparedStatement.setString(1, "zed");
            //6.向数据库发出sql，执行查询，查询出结果集
            resultSet = preparedStatement.executeQuery();
            //7.遍历查询结果集
            while (resultSet.next()) {
                int id = resultSet.getInt("id");
                String username = resultSet.getString("username");
                User user = new User();
                user.setId(id);
                user.setUsername(username);
                System.out.println(user);
            }
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } finally {
            //8.释放资源
            if (resultSet != null) {
                resultSet.close();
            }
            if (preparedStatement != null) {
                preparedStatement.close();
            }
            if (connection != null) {
                connection.close();
            }
        }
    }

2.插入

public static void main(String[] args) throws SQLException {
        Connection connection = null;
        PreparedStatement preparedStatement = null;
        try {
            //1.加载数据库驱动
            Class.forName("com.mysql.jdbc.Driver");
            //2.通过驱动管理类获取数据库链接
            connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/test_jdbc","root","123456");
            //3.定义sql语句，?表示占位符
            String sql = "insert into user (id, username) values (?, ?)";
            //4.获取预处理statement
            preparedStatement = connection.prepareStatement(sql);
            //5.设置参数，第一个参数为sql语句中参数的序号（从1开始），第二个参数为设置的参数值
            preparedStatement.setInt(1, 7);
            preparedStatement.setString(2, "lux");
            //6.向数据库发出sql，执行插入，获取受影响的行数
            int rows = preparedStatement.executeUpdate();
            System.out.println("受影响的行数：" + rows);
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } finally {
            //7.释放资源
            if (preparedStatement != null) {
                preparedStatement.close();
            }
            if (connection != null) {
                connection.close();
            }
        }
    }

3.更新

public static void main(String[] args) throws SQLException {
        Connection connection = null;
        PreparedStatement preparedStatement = null;
        try {
            //1.加载数据库驱动
            Class.forName("com.mysql.jdbc.Driver");
            //2.通过驱动管理类获取数据库链接
            connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/test_jdbc","root","123456");
            //3.定义sql语句，?表示占位符
            String sql = "update user set username = ? where id = ?";
            //4.获取预处理statement
            preparedStatement = connection.prepareStatement(sql);
            //5.设置参数，第一个参数为sql语句中参数的序号（从1开始），第二个参数为设置的参数值
            preparedStatement.setString(1, "jax");
            preparedStatement.setInt(2, 7);
            //6.向数据库发出sql，执行更新，获取受影响的行数
            int rows = preparedStatement.executeUpdate();
            System.out.println("受影响的行数：" + rows);
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } finally {
            //7.释放资源
            if (preparedStatement != null) {
                preparedStatement.close();
            }
            if (connection != null) {
                connection.close();
            }
        }
    }

4.删除

public static void main(String[] args) throws SQLException {
        Connection connection = null;
        PreparedStatement preparedStatement = null;
        try {
            //1.加载数据库驱动
            Class.forName("com.mysql.jdbc.Driver");
            //2.通过驱动管理类获取数据库链接
            connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/test_jdbc","root","123456");
            //3.定义sql语句，?表示占位符
            String sql = "delete from user where id = ?";
            //4.获取预处理statement
            preparedStatement = connection.prepareStatement(sql);
            //5.设置参数，第一个参数为sql语句中参数的序号（从1开始）
            preparedStatement.setInt(1, 7);
            //6.向数据库发出sql，执行删除，获取受影响的行数
            int rows = preparedStatement.executeUpdate();
            System.out.println("受影响的行数：" + rows);
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } finally {
            //7.释放资源
            if (preparedStatement != null) {
                preparedStatement.close();
            }
            if (connection != null) {
                connection.close();
            }
        }
    }

总结

1）加载数据库驱动

2）建立链接

3）执行SQL语句

4）处理结果

5）关闭链接