我是靠谱客的博主 漂亮小虾米，最近开发中收集的这篇文章主要介绍JDBC系列一之--------使用JDBC连接Mysql数据库进行增删改查操作(详细版)一、连接数据库二、对Mysql 数据库进行增删改操作三、对数据库进行查询操作1.建立一个Customer 类JDBC系列，觉得挺不错的，现在分享给大家，希望可以做个参考。
概述
最近发现了一个挺厉害的人工智能学习网站，内容通俗易懂，风趣幽默，感兴趣的可以点击此链接进行查看：床长人工智能教程
废话不多说，请看正文！
目录
一、连接数据库
1.我的java和mysql版本
2.连接数据库的版本一
3.连接数据库的版本二
4.连接数据库的版本三
5.连接数据库的版本四
6.连接数据库的版本五
7.连接数据库的最终版本（将连接数据库和关闭数据库封装成一个类，减少重复代码）
二、对Mysql 数据库进行增删改操作
1.我的数据库 customers 表的内容
2.对数据库中进行插入数据（没有使用连接数据库的封装库，区别请对比2和3）
3.对数据库进行修改操作（请与第2点进行对比一下连接数据库和关闭数据库的差别）
4.对数据库通用的增删改操作（终极版）
三、对数据库进行查询操作
1.建立一个Customer 类
2.对customers表的查询实例
3.对customers表通用的查询操作（进阶版）
4.针对于不同的表的通用的查询操作，返回表中的一条记录
5.针对于不同的表的通用的查询操作，返回表中的多条记录
JDBC系列
JDBC系列一之------使用JDBC连接Mysql数据库进行增删改查操作(详细版)
JDBC系列二之------Jdbc操作Mysql BLOB类型数据
JDBC系列三之------java下Mysql的批量插入的优化
JDBC系列四之------JDBC对mysql数据库事务处理
JDBC系列五之------java的Dao及其实现类
JDBC系列六之------JDBC数据库连接池
一、连接数据库
1.我的java和mysql版本
| java | Mysql |
| 1.8 | 8.0 |
2.连接数据库的版本一
//方法一
@Test
public void testConnection1() throws SQLException{
//1.获取Driver 类对象
Driver driver = new com.mysql.cj.jdbc.Driver();
String url = "jdbc:mysql://localhost:3306/test?" +
"useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai";
// 将用户名和密码封装在Properties中
Properties info = new Properties();
info.setProperty("user", "root");
info.setProperty("password", "root");
Connection conn = driver.connect(url, info);
System.out.println(conn);
}3.连接数据库的版本二
//方法二：对方式一进行迭代，使得如下程序不出现第三方API,让程序有更好的可移植性
@Test
public void testConnection2() throws Exception{
//1. 获取Driver类对象，使用反射
Class clazz = Class.forName("com.mysql.cj.jdbc.Driver");
Driver driver = (Driver) clazz.newInstance();
//2. 提供要连接的数据库
String url = "jdbc:mysql://localhost:3306/test?" +
"useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai";
//3. 将用户名和密码封装在Properties中
Properties info = new Properties();
info.setProperty("user", "root");
info.setProperty("password", "root");
//4.获取连接
Connection conn = driver.connect(url, info);
System.out.println(conn);
}4.连接数据库的版本三
//方法三：使用DriverManger替换Driver
@Test
public void testConnection3() throws Exception{
//1. 获取Driver类对象，使用反射
Class clazz = Class.forName("com.mysql.cj.jdbc.Driver");
Driver driver = (Driver) clazz.newInstance();
//2.提供另外的三个基本信息
String url = "jdbc:mysql://localhost:3306/test" +
"?useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai";
String user = "root";
String password = "root";
//注册驱动
DriverManager.registerDriver(driver);
//获取连接
Connection conn= DriverManager.getConnection(url, user, password);
System.out.println(conn);
}5.连接数据库的版本四
//方法四：
@Test
public void testConnection4() throws Exception{
//1.提供三个基本信息
String url = "jdbc:mysql://localhost:3306/test" +
"?useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai";
String user = "root";
String password = "root";
//2. 获取Driver类对象，使用反射
Class clazz = Class.forName("com.mysql.cj.jdbc.Driver");
//相较于方式三，可以省略以下代码
// Driver driver = (Driver) clazz.newInstance();
// //注册驱动
// DriverManager.registerDriver(driver);
//3.获取连接
Connection conn = DriverManager.getConnection(url, user, password);
System.out.println(conn);
}
6.连接数据库的版本五
jdbc.properties 文件内容
user=root
password=659647
url=jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai
driverClass=com.mysql.cj.jdbc.Driver//方式五:将数据库连接的基本数据声明在配置文件中，通过读取配置文件的信息，获取连接
/*
* 这种的好处
* 1.实现数据与代码的分离，实现了解耦。
* 2.如果需要修改配置文件信息，可以避免程序重新打包
* */
@Test
public void testConnection5() throws Exception{
//1.读取配置文件的基本信息
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 driverClass = pros.getProperty("driverClass");
//2.加载驱动
Class.forName(driverClass);
//3.获取连接
Connection conn = DriverManager.getConnection(url, user, password);
System.out.println(conn);
}
7.连接数据库的最终版本（将连接数据库和关闭数据库封装成一个类，减少重复代码）
jdbc.properties 文件内容
user=root
password=659647
url=jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai
driverClass=com.mysql.cj.jdbc.Driver/**
* 操作数据库的工具类
*/
public class JDBCUtils {
/*
* 获取数据库的连接
* */
public static Connection getConnection() throws Exception{
//1.读取配置文件的基本信息
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 driverClass = pros.getProperty("driverClass");
//2.加载驱动
Class.forName(driverClass);
//3.获取连接
Connection conn = DriverManager.getConnection(url, user, password);
return conn;
}
/*
* 关闭连接和Statement的操作
* */
public static void closeResource(Connection conn, Statement ps){
try {
if( ps != null)
ps.close();
} catch (SQLException e) {
e.printStackTrace();
}
try {
if(conn != null)
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
/*
* 关闭资源的操作
* */
public static void closeResource(Connection conn, Statement ps , ResultSet rs){
try {
if( ps != null)
ps.close();
} catch (SQLException e) {
e.printStackTrace();
}
try {
if(conn != null)
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
try {
if(rs != null)
rs.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
二、对Mysql 数据库进行增删改操作
1.我的数据库 customers 表的内容
2.对数据库中进行插入数据（没有使用连接数据库的封装库，区别请对比2和3）
//向customers表中添加一条数据
@Test
public void testInsert() {
Connection connection = null;
PreparedStatement ps = null;
try {
//1.读取配置文件的基本信息
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 driverClass = pros.getProperty("driverClass");
//2.加载驱动
Class.forName(driverClass);
//3.获取连接
connection = DriverManager.getConnection(url, user, password);
//4.预编译sql语句，返回PreparedStatement的实例
String sql = "insert into customers(name,email,birth)value(?,?,?)";
ps = connection.prepareStatement(sql);
//5.填充占位符
ps.setString(1,"哪吒");
ps.setString(2,"nezha@gmail.com");
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
Date date = sdf.parse("1000-01-01");
ps.setDate(3,new java.sql.Date(date.getTime()));
//6.执行sql
ps.execute();
} catch (Exception e) {
e.printStackTrace();
}finally {
//7.资源关闭
try {
if( ps != null)
ps.close();
} catch (SQLException e) {
e.printStackTrace();
}
try {
if(connection != null)
connection.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}3.对数据库进行修改操作（请与第2点进行对比一下连接数据库和关闭数据库的差别）
//修改customers表中的数据
@Test
public void testUpdate(){
Connection conn = null;
PreparedStatement ps = null;
try {
//1.获取数据库连接
conn = JDBCUtils.getConnection();
//2.预编译sql语句，返回PreparedStatement的实列
String sql = "update customers set name = ? where id = ?";
ps = conn.prepareStatement(sql);
//3.填充占位符
ps.setObject(1,"莫扎特");
ps.setObject(2,18);
//4.执行
ps.execute();
} catch (Exception e) {
e.printStackTrace();
}finally {
//5.资源的关闭
JDBCUtils.closeResource(conn,ps);
}
}4.对数据库通用的增删改操作（终极版）
//通用的增删改操作
public void update(String sql, Object ...args){//sql语句的占位符数量和可变形参的数量相同
Connection conn = null;
PreparedStatement ps = null;
try {
//1.获取数据库连接
conn = JDBCUtils.getConnection();
//2.预编译sql语句，返回PreparedStatement的实列
ps = conn.prepareStatement(sql);
//3.填充占位符
for (int i=0;i<args.length;i++){
ps.setObject(i + 1, args[i]);
}
//4.执行
ps.execute();
} catch (Exception e) {
e.printStackTrace();
}finally {
//5.资源的关闭
JDBCUtils.closeResource(conn,ps);
}
}对上述的代码进行测试
@Test
public void testCommonUpdate(){
// String sql = "delete from customers where id = ?";
// update(sql,4);
//order 是sql中的关键字，当order作为一个表名时要添加符合: `
String sql = "update `order` set order_name = ? where order_id = ?";
update(sql,"DD",2);
}三、对数据库进行查询操作
1.建立一个Customer 类
/*
* ORM编程思想 （object relational mapping）
* 一个数据表对应一个java类
* 表中的每一条记录对应java类的一个对象
* 表中的一个字段对应java类的一个属性
* */
public class Customer {
private int id;
private String name;
private String email;
public Customer() {
super();
}
public Customer(int id, String name, String email, Date birth) {
this.id = id;
this.name = name;
this.email = email;
this.birth = birth;
}
public int getId() {
return id;
}
public void setId(int id) {
this.id = id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getEmail() {
return email;
}
public void setEmail(String email) {
this.email = email;
}
public Date getBirth() {
return birth;
}
public void setBirth(Date birth) {
this.birth = birth;
}
private Date birth;
}
2.对customers表的查询实例
@Test
public void testQuery1(){
Connection conn = null;
PreparedStatement ps = null;
ResultSet resultSet = null;
try {
//获取连接
conn = JDBCUtils.getConnection();
String sql = "select id, name,email,birth from customers where id = ?";
//预编译sql语句
ps = conn.prepareStatement(sql);
//填充占位符
ps.setObject(1,1);
//执行并返回结果集
resultSet = ps.executeQuery();
//处理结果集
if (resultSet.next()){//判断结果集下一条是否有数据如果有数据放回true,并自动指向下一条数据,
// 没有数据返回false.
//获取当前数据的各个字段值
int id = resultSet.getInt(1);
String name = resultSet.getString(2);
String email = resultSet.getString(3);
Date birth = resultSet.getDate(4);
//输出方式：
// Object[] data = new Object[]{id,name,email,birth};
//输出方式：将数据封装成要给对象(推荐)
Customer customer = new Customer(id, name, email, birth);
System.out.println(customer);
}
} catch (Exception e) {
e.printStackTrace();
}finally {
//关闭资源
JDBCUtils.closeResource(conn,ps,resultSet);
}
}3.对customers表通用的查询操作（进阶版）
/*
* 针对于customers表通用的查询操作
* */
public Customer queryForCustomers(String sql, Object ...args){
Connection conn = null;
PreparedStatement ps = null;
ResultSet rs = null;
try {
//获取连接
conn = JDBCUtils.getConnection();
//预编译sql语句
ps = conn.prepareStatement(sql);
//填充占位符
for (int i = 0; i < args.length; i++){
ps.setObject(i + 1,args[i]);
}
//执行并返回结果集
rs = ps.executeQuery();
//获取结果集元素据
ResultSetMetaData rsmd = rs.getMetaData();
//通过ResultSetMetaData获取数据集中的列数
int columnCount = rsmd.getColumnCount();
if (rs.next()){
Customer cust = new Customer();
for (int i = 0;i < columnCount; i++){
Object columnValue = rs.getObject(i + 1);
//获取每个列的列名:getColumnName(不推荐使用)
//获取每个列的别名：getColumnLabel
//String columnName = rsmd.getColumnName(i + 1);
String columnLabel = rsmd.getColumnLabel(i + 1);
//给cust 对象指定的columnName属性赋值为columnValue,通过反射
Field field = Customer.class.getDeclaredField(columnLabel);
field.setAccessible(true);
field.set(cust,columnValue);
}
return cust;
}
} catch (Exception e) {
e.printStackTrace();
}finally {
JDBCUtils.closeResource(conn,ps,rs);
}
return null;
}对上面代码的测试类
@Test
public void testQueryForCustomers(){
String sql = "select id, name,email,birth from customers where id = ?";
Customer customer = queryForCustomers(sql, 13);
System.out.println(customer);
String sql1 = "select id, name,email,birth from customers where name = ?";
Customer customer1 = queryForCustomers(sql1, "成龙");
System.out.println(customer1);
}4.针对于不同的表的通用的查询操作，返回表中的一条记录
/**
*
* 针对于不同的表的通用的查询操作，返回表中的一条记录
*/
public <T> T getInstance(Class<T> clazz,String sql, Object... args) {
Connection conn = null;
PreparedStatement ps = null;
ResultSet rs = null;
try {
conn = JDBCUtils.getConnection();
ps = conn.prepareStatement(sql);
for (int i = 0; i < args.length; i++) {
ps.setObject(i + 1, args[i]);
}
rs = ps.executeQuery();
// 获取结果集的元数据 :ResultSetMetaData
ResultSetMetaData rsmd = rs.getMetaData();
// 通过ResultSetMetaData获取结果集中的列数
int columnCount = rsmd.getColumnCount();
if (rs.next()) {
T t = clazz.newInstance();
// 处理结果集一行数据中的每一个列
for (int i = 0; i < columnCount; i++) {
// 获取列值
Object columValue = rs.getObject(i + 1);
// 获取每个列的列名
// String columnName = rsmd.getColumnName(i + 1);
String columnLabel = rsmd.getColumnLabel(i + 1);
// 给t对象指定的columnName属性，赋值为columValue：通过反射
Field field = clazz.getDeclaredField(columnLabel);
field.setAccessible(true);
field.set(t, columValue);
}
return t;
}
} catch (Exception e) {
e.printStackTrace();
} finally {
JDBCUtils.closeResource(conn, ps, rs);
}
return null;
}对上面代码的测试类
@Test
public void testGetInstance(){
String sql = "select id,name,email from customers where id = ?";
Customer customer = getInstance(Customer.class,sql,12);
System.out.println(customer);
// String sql1 = "select order_id orderId,order_name orderName from `order` where order_id = ?";
// Order order = getInstance(Order.class, sql1, 1);
// System.out.println(order);
}5.针对于不同的表的通用的查询操作，返回表中的多条记录
public <T> List<T> getForList(Class<T> clazz, String sql, Object... args){
Connection conn = null;
PreparedStatement ps = null;
ResultSet rs = null;
try {
conn = JDBCUtils.getConnection();
ps = conn.prepareStatement(sql);
for (int i = 0; i < args.length; i++) {
ps.setObject(i + 1, args[i]);
}
rs = ps.executeQuery();
// 获取结果集的元数据 :ResultSetMetaData
ResultSetMetaData rsmd = rs.getMetaData();
// 通过ResultSetMetaData获取结果集中的列数
int columnCount = rsmd.getColumnCount();
//创建集合对象
ArrayList<T> list = new ArrayList<T>();
while (rs.next()) {
T t = clazz.newInstance();
// 处理结果集一行数据中的每一个列:给t对象指定的属性赋值
for (int i = 0; i < columnCount; i++) {
// 获取列值
Object columValue = rs.getObject(i + 1);
// 获取每个列的列名
// String columnName = rsmd.getColumnName(i + 1);
String columnLabel = rsmd.getColumnLabel(i + 1);
// 给t对象指定的columnName属性，赋值为columValue：通过反射
Field field = clazz.getDeclaredField(columnLabel);
field.setAccessible(true);
field.set(t, columValue);
}
list.add(t);
}
return list;
} catch (Exception e) {
e.printStackTrace();
} finally {
JDBCUtils.closeResource(conn, ps, rs);
}
return null;
}对上面代码的测试类
/**
*
* 针对于不同的表的通用的查询操作，返回表中的多条记录
*/
@Test
public void testGetForList(){
String sql = "select id,name,email from customers where id < ?";
List<Customer> list = getForList(Customer.class,sql,12);
list.forEach(System.out::println);
String sql1 = "select order_id orderId,order_name orderName from `order`";
List<Order> orderList = getForList(Order.class, sql1);
orderList.forEach(System.out::println);
}JDBC系列
-
JDBC系列一之------使用JDBC连接Mysql数据库进行增删改查操作(详细版)
-
JDBC系列二之------Jdbc操作Mysql BLOB类型数据
-
JDBC系列三之------java下Mysql的批量插入的优化
-
JDBC系列四之------JDBC对mysql数据库事务处理
-
JDBC系列五之------java的Dao及其实现类
-
JDBC系列六之------JDBC数据库连接池
最后
以上就是漂亮小虾米为你收集整理的JDBC系列一之--------使用JDBC连接Mysql数据库进行增删改查操作(详细版)一、连接数据库二、对Mysql 数据库进行增删改操作三、对数据库进行查询操作1.建立一个Customer 类JDBC系列的全部内容，希望文章能够帮你解决JDBC系列一之--------使用JDBC连接Mysql数据库进行增删改查操作(详细版)一、连接数据库二、对Mysql 数据库进行增删改操作三、对数据库进行查询操作1.建立一个Customer 类JDBC系列所遇到的程序开发问题。
如果觉得靠谱客网站的内容还不错，欢迎将靠谱客网站推荐给程序员好友。
本图文内容来源于网友提供，作为学习参考使用，或来自网络收集整理，版权属于原作者所有。
![【剑指offer】——【python中return函数中的and和or表达式的返回值】1、# and 结果为真，返回最后一个表达式的结果，若结果为假返回第一个为假的表达式的结果2、# or 结果为真，返回第一个为真的表达式的结果，若结果为假，返回最后一个表达式的结果3、应用[剑指 Offer 64. 求1+2+…+n]](/uploads/reation/bcimg8.png)
发表评论 取消回复