JDBC实现简单增删改查
发布时间 - 2025-07-12 00:00:00 点击率:次jdbc,全称为java database connectivity(java数据库连接),主要用于java与数据库的连接。
整个连接过程如下图所示:
-
数据库驱动: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;
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(" + "idINT UNSIGNED AUTO_INCREMENT," + "user_nameVARCHAR(100)," + "user_passwordVARCHAR(100)," + "user_ageINT(11)," + "PRIMARY KEY (id)" + ")ENGINE=InnoDB DEFAULT CHARSET=utf8;"; Connection conn = DBUtil.getConnection(); //开启事务 conn.setAutoCommit(f
alse);
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中将个别页面强制横屏其他页面竖屏


alse);
PreparedStatement preparedStatement = conn.prepareStatement(sql);
preparedStatement.executeUpdate();
//提交事务
conn.commit();
//要注意关闭连接(在实际中最好不要像这样关闭,最好标准一点)
conn.close();
}