JDBC实现简单增删改查

发布时间 - 2025-07-12 00:00:00    点击率:

jdbc,全称为java database connectivity(java数据库连接),主要用于java与数据库的连接。

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

  1. 数据库驱动:Driver

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

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

    加载相应的驱动需要导入相应的包,例如对于MySQL,需要导入mysql-connector-java-5.1.13-bin.jar,否则无法正常执行。

  2. 获取数据库连接:Connection

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

  3. 执行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语句执行。

  4. 结果集: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;
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 {
/**

  • 创建表 */ 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(); }
/**
 * 增加数据
 */
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();
}

}

这是我的文件结构:

注意要导入相应的包,大家需要自行下载MySQL的依赖包。


# mysql  # oracle  # 工具  # sql语句  # string类  # red  # Java  # sql  # String  # Float  # Boolean  # date  # class  # 对象  # database  # 数据库  # 加载  # 配置文件  # 不带  # 主要用于  # 老王  # 的是  # 这是  # 连接数据库  # 批处理  # 要注意 


相关栏目: 【 网站优化151355 】 【 网络推广146373 】 【 网络技术251813 】 【 AI营销90571


相关推荐: 作用域操作符会触发自动加载吗_php类自动加载机制与::调用【教程】  Win11怎么设置默认图片查看器_Windows11照片应用关联设置  javascript中对象的定义、使用以及对象和原型链操作小结  Laravel如何使用Scope本地作用域_Laravel模型常用查询逻辑封装技巧【手册】  如何用虚拟主机快速搭建网站?详细步骤解析  如何快速登录WAP自助建站平台?  专业企业网站设计制作公司,如何理解商贸企业的统一配送和分销网络建设?  Linux安全能力提升路径_长期防护思维说明【指导】  Laravel如何配置中间件Middleware_Laravel自定义中间件拦截请求与权限校验【步骤】  php485函数参数是什么意思_php485各参数详细说明【介绍】  ,网页ppt怎么弄成自己的ppt?  如何在阿里云虚拟机上搭建网站?步骤解析与避坑指南  Internet Explorer官网直接进入 IE浏览器在线体验版网址  Laravel用户密码怎么加密_Laravel Hash门面使用教程  Laravel如何处理表单验证?(Requests代码示例)  想要更高端的建设网站,这些原则一定要坚持!  Laravel如何实现用户角色和权限系统_Laravel角色权限管理机制  Laravel如何使用Service Provider注册服务_Laravel服务提供者配置与加载  Laravel如何实现用户密码重置功能?(完整流程代码)  python中快速进行多个字符替换的方法小结  郑州企业网站制作公司,郑州招聘网站有哪些?  如何在阿里云虚拟主机上快速搭建个人网站?  Laravel如何配置Horizon来管理队列?(安装和使用)  北京网页设计制作网站有哪些,继续教育自动播放怎么设置?  Laravel怎么集成Log日志记录_Laravel单文件与每日日志配置及自定义通道【详解】  文字头像制作网站推荐软件,醒图能自动配文字吗?  Laravel如何使用Passport实现OAuth2?(完整配置步骤)  如何在 Go 中优雅地映射具有动态字段的 JSON 对象到结构体  长沙企业网站制作哪家好,长沙水业集团官方网站?  Swift中循环语句中的转移语句 break 和 continue  如何在云主机上快速搭建网站?  矢量图网站制作软件,用千图网的一张矢量图做公司app首页,该网站并未说明版权等问题,这样做算不算侵权?应该如何解决?  油猴 教程,油猴搜脚本为什么会网页无法显示?  如何在建站主机中优化服务器配置?  弹幕视频网站制作教程下载,弹幕视频网站是什么意思?  Laravel如何与Pusher实现实时通信?(WebSocket示例)  怎么制作网站设计模板图片,有电商商品详情页面的免费模板素材网站推荐吗?  Win11怎么查看显卡温度 Win11任务管理器查看GPU温度【技巧】  Laravel怎么防止CSRF攻击_Laravel CSRF保护中间件原理与实践  HTML5空格在Angular项目里怎么处理_Angular中空格的渲染问题【详解】  制作公司内部网站有哪些,内网如何建网站?  Windows11怎样设置电源计划_Windows11电源计划调整攻略【指南】  免费制作统计图的网站有哪些,如何看待现如今年轻人买房难的情况?  Laravel怎么写单元测试_PHPUnit在Laravel项目中的基础测试入门  Laravel的辅助函数有哪些_Laravel常用Helpers函数提高开发效率  edge浏览器无法安装扩展 edge浏览器插件安装失败【解决方法】  Laravel如何发送系统通知?(Notification渠道示例)  Laravel如何与Docker(Sail)协同开发?(环境搭建教程)  Laravel如何实现全文搜索_Laravel Scout集成Algolia或Meilisearch教程  iOS中将个别页面强制横屏其他页面竖屏