什么是JDBC
Java Data Base Connectivity:Java数据库连接
JDBC 作用
通过JDBC可以让Java程序操作数据库
JDBC 本质
官方(Sun公司)定义的一套操作所有关系型数据库的规则,即接口(API)
各个数据库厂商去实现这套接口,提供数据库驱动jar包
我们可以使用这套接口(JDBC)编程,真正执行的代码是驱动jar包中的实现类
JDBC的好处
我们只需要会调用JDBC接口中的方法即可,使用简单
使用同一套Java代码,进行少量的修改就可以访问其他JDBC支持的数据库
JDBC的使用步骤
1.注册驱动
2.获取数据库连接
3.获取执SQL语句对象
4.执行SQL语句并返回结果
5.处理结果
6.释放资源
1.static void registerDriver(Driver driver) 向 DriverManager 注册给定驱动程序。
MySQL 5之后的驱动包,可以省略注册驱动的步骤
自动加载jar包中META-INF/services/java.sql.Driver文件中的驱动类
2.DriverManager.getConnection(url,账户,密码)
url:连接数据库的URL,用于说明连接数据库的位置
连接数据库的URL地址格式:协议名:子协议://服务器名或IP地址:端口号/数据库名
如果是本地服务器,端口号是默认的3306,则可以简写
3.Statement createStatement()
创建一个 Statement 对象来将 SQL 语句发送到数据库
4.Statement中执行SQL语句的方法
int executeUpdate(String sql) 用于执行除查询外的SQL语句
ResultSet executeQuery(String sql) 用于执行查询语句, 返回查询到的结果集
5.用ResultSet来接收返回值
//代码使用MySQL8
public static void main(String[] args) throws SQLException {
// 1.注册驱动(自动注册)
// 2.获取连接
Connection connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/db1?useSSL=false&useUnicode=true&characterEncoding=UTF8&serverTimezone=GMT", "root", "1234");
// 3.获取Statement
Statement statement = connection.createStatement();
// 4.执行SQL语句
String sql = "select * from account";
// 5.处理结果
ArrayList<User> list = new ArrayList<>();
ResultSet resultSet = statement.executeQuery(sql);
//直接打印是一个地址值,要循环打印
//resultSet.next()是否有下一行,有返回true,无则返回false
while (resultSet.next()){
int id = resultSet.getInt("id");
String name = resultSet.getString("NAME");
String balance = resultSet.getString("balance");
//System.out.println("id:"+id+",name:"+name+",balance:"+balance);
User user = new User(id, name, balance);
list.add(user);
}
// 6.关闭资源
statement.close();
connection.close();
for (User user : list) {
System.out.println(user);
}
}
No suitable driver found for jdbc:mysql://Localhost:3306/db 没有导入驱动
Unknown database 'database1' 找不到数据库
Access denied for user'root'@'localhost' (using password: YES) 密码输入错误
如果url有问题会报The driver has not received any packets from the server.
| 方法名 | 说明 |
|---|---|
| setAutoCommit() | 默认true:关闭事务,false:开启事务 |
| commit() | 提交事务 |
| rollback() | 回滚事务 |
使用步骤
1.注册驱动
2.获取连接
3.开启事务
4.获取到Statement
5.Statement执行SQL
6.提交或回滚事务
7.关闭资源
可以将事务用动态代理来帮助我们完成。
public static void main(String[] args) {
Connection connection = null;
Statement statement =null;
try {
// 1.注册驱动(自动注册)
// 2.获取连接
connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/db1?useSSL=false&useUnicode=true&characterEncoding=UTF8&serverTimezone=GMT", "root", "1234");
// 3.开启事务 将自动提交关闭 setAutoCommit false 表示开启手动提交事务,如果设置为true表示自动提交事务,默认是true
connection.setAutoCommit(false);
// 4.获取到Statement
statement = connection.createStatement();
// 5.Statement执行SQL
// 张三-500
String sql = "update account set balance = balance - 500 where id = 1";
//int i = 10/0;
// 李四+500
String sql2 = "update account set balance = balance +500 where id = 2";
statement.executeUpdate(sql);
statement.executeUpdate(sql2);
// 6.成功提交事务
connection.commit();
System.out.println("成功提交事务");
} catch (SQLException e) {
try {
if(connection!=null){
// 6.失败回滚事务
connection.rollback();
}
e.printStackTrace();
} catch (SQLException ex) {
ex.printStackTrace();
}
}finally {
try {
if(statement!=null){
statement.close();
}
if(connection!=null){
connection.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
}
如果你对本文有疑问,你可以在文章下方对我留言,敬请指正,对于每个留言我都会认真查看。