JDBC实现简单增删改查-linux运维-PHP中文网

JDBC实现简单增删改查

絕刀狂花

发布： 2025-07-12 10:30:02

原创

627人浏览过

jdbc，全称为java database connectivity（java数据库连接），主要用于java与数据库的连接。

整个连接过程如下图所示：

JDBC实现简单增删改查

数据库驱动：Driver

加载MySQL驱动：Class.forName("com.mysql.jdbc.Driver");

加载Oracle驱动：Class.forName("oracle.jdbc.driver.OracleDriver");

加载相应的驱动需要导入相应的包，例如对于MySQL，需要导入mysql-connector-java-5.1.13-bin.jar，否则无法正常执行。
获取数据库连接：Connection

Connection类主要用于连接数据库，通常通过DriverManager.getConnection()来获取一个连接对象。该方法有三个参数，分别是url、user和password，对应的是要连接的数据库、用户名和密码。例如：url=jdbc:mysql://localhost:3306/jdbc?useUnicode=true&characterEncoding=utf-8，user=root，password=root。
执行SQL语句：Statement

Statement对象用于执行SQL语句，有以下三种：

（1）Statement对象用于执行不带参数的简单SQL语句；

（2）PreparedStatement对象用于执行带或不带参数的预编译SQL语句；

（3）CallableStatement对象用于执行对数据库已存储过程的调用。

Statement的常用方法：

（1）executeQuery()方法：运行查询语句，返回ResultSet对象。

（2）executeUpdate()方法：运行增、删、改操作，返回更新的行数。

（3）addBatch(String sql)：将多条SQL语句放到一个批处理中。

（4）executeBatch()：向数据库发送一批SQL语句执行。
结果集：ResultSet

执行executeQuery()方法后返回的结果集。

常用方法：

（1）getString(String columnName)：获取当前行的某一String类型的字段。

（2）getFloat(String columnName)：获取当前行的某一Float类型的字段。

（3）getDate(String columnName)：获取当前行的某一Date类型的字段。

（4）getBoolean(String columnName)：获取当前行的某一Boolean类型的字段。

（5）getObject(String columnName)：获取当前行的某一任意类型的字段。

（6）next()：移动到下一行。

实际代码：

首先，建立一个配置文件，内容如下：

#数据库驱动
driver=com.mysql.jdbc.Driver
#连接数据库的URL
url=jdbc:mysql://localhost:3306/jdbc?useUnicode=true&characterEncoding=utf-8
#用户名
user=root
#密码
password=root

登录后复制

接着，编写一个连接数据库的通用工具类：

public class DBUtil {
    private static String driver;
    private static String url;
    private static String user;
    private static String password;
<pre class="brush:php;toolbar:false">static {
    try {
        //读取配置文件
        InputStream in = DBUtil.class.getResourceAsStream("db.properties");
        Properties properties = new Properties();
        //加载配置文件
        properties.load(in);
        //获取配置文件中的数据
        driver = properties.getProperty("driver");
        url = properties.getProperty("url");
        user = properties.getProperty("user");
        password = properties.getProperty("password");
        //加载数据库连接驱动
        Class.forName(driver);
    } catch (Exception e) {
        e.printStackTrace();
    }
}

/**
 * 获取一个数据库连接
 */
public static Connection getConnection() throws SQLException {
    return DriverManager.getConnection(url, user, password);
}

登录后复制

}

实现简单的增删改查：

public class jdbcTest {
/**</p><ul><li>创建表
*/
public static void createTable() throws SQLException {
String sql = "CREATE TABLE IF NOT EXISTS user(" +
"id INT UNSIGNED AUTO_INCREMENT," +
" user_name VARCHAR(100)," +
" user_password VARCHAR(100)," +
" user_age INT(11)," +
"PRIMARY KEY ( id )" +
")ENGINE=InnoDB DEFAULT CHARSET=utf8;";
Connection conn = DBUtil.getConnection();
//开启事务
conn.setAutoCommit(false);
PreparedStatement preparedStatement = conn.prepareStatement(sql);
preparedStatement.executeUpdate();
//提交事务
conn.commit();
//要注意关闭连接（在实际中最好不要像这样关闭，最好标准一点）
conn.close();
}</li></ul><pre class="brush:php;toolbar:false">/**
 * 增加数据
 */
public static void add() throws SQLException {
    String sql = "INSERT INTO USER (user_name,user_password,user_age) VALUES('老王','123456',18)";
    Connection conn = DBUtil.getConnection();
    conn.setAutoCommit(false);
    PreparedStatement preparedStatement = conn.prepareStatement(sql);
    preparedStatement.executeUpdate();
    conn.commit();
    conn.close();
}

/**
 * 删除数据
 */
public static void delete() throws SQLException {
    String sql = "DELETE FROM USER WHERE USER.user_name = '老王'";
    Connection conn = DBUtil.getConnection();
    conn.setAutoCommit(false);
    PreparedStatement preparedStatement = conn.prepareStatement(sql);
    preparedStatement.executeUpdate();
    conn.commit();
    conn.close();
}

/**
 * 修改数据
 */
public static void update() throws SQLException {
    String sql = "UPDATE USER SET USER.user_name = '老李'";
    Connection conn = DBUtil.getConnection();
    conn.setAutoCommit(false);
    PreparedStatement preparedStatement = conn.prepareStatement(sql);
    preparedStatement.executeUpdate();
    conn.commit();
    conn.close();
}

/**
 * 查找数据
 */
public static void query() throws SQLException {
    String sql = "SELECT * FROM USER";
    Connection conn = DBUtil.getConnection();
    conn.setAutoCommit(false);
    PreparedStatement preparedStatement = conn.prepareStatement(sql);
    //执行查询语句并返回结果集
    ResultSet resultSet = preparedStatement.executeQuery();
    while (resultSet.next()) {
        //注意：这里要与数据库里的字段对应
        String username = resultSet.getString("user_name");
        String password = resultSet.getString("user_password");
        String age = resultSet.getString("user_age");
        System.out.println(username + " " + password + " " + age);
    }
    conn.commit();
    conn.close();
}

登录后复制

}

这是我的文件结构：

JDBC实现简单增删改查