JDBC
1：数据库驱动
例如：声卡，显卡，驱动等；
2：JDBC
SUN公司为了简化开发人员的(对数据库的统一）操作，提供了一个(Java操作数据库的)规范，俗称JDBC这些规范的实现由具体的厂商去做。
对于开发人员来说，我们只需要掌握JDBC接口的操作即可!
3：第一个JDBC程序
创建数据库
CREATE DATABASE jdbcStudy CHARACTER SET utf8 COLLATE utf8_general_ci;
USE jdbcStudy;
CREATE TABLE `users`(
id INT PRIMARY KEY,
NAME VARCHAR(40),
PASSWORD VARCHAR(40),
email VARCHAR(60),
birthday DATE
);
INSERT INTO `users`(id,NAME,PASSWORD,email,birthday)
VALUES(1,'zhansan','123456','zs@sina.com','1980-12-04'),
(2,'lisi','123456','lisi@sina.com','1981-12-04'),
(3,'wangwu','123456','wangwu@sina.com','1979-12-04')
1：创建一个普通的项目；
2：导入数据库的驱动，添加的jar
-mysql-connector-java-5.1.47.jar
在IDEA中创建 lib ,把包添加到 lib 目录下
3：编写测试代码
import java.sql.*;
//我的第一个jdbc程序
public class jdbcfristDemo {
public static void main(String[] args) throws ClassNotFoundException, SQLException {
//1、加载驱动
Class.forName("com.mysql.cj.jdbc.Driver");//固定写法
//2、用户信息和url
//useUnicode=true&characterEncoding=utf8&useSSL=true
String url = "jdbc:mysql://localhost:3306/jdbcstudy?useUnicode=true&characterEncoding=utf8&useSSL=true";
String username = "root";
String password = "root";
//3、连接成功，数据库对象；
//connection(关系关联)代表数据库
Connection connection = DriverManager.getConnection(url, username, password);
//4、执行sql的对象；statement执行sql的对象
//createStatement创建一个 Statement 对象来将 SQL 语句发送到数据库
Statement statement = connection.createStatement();
//5、执行sql的对象； 去执行sql语句；可能存在结果，查看返回结果
String sql = "SELECT *FROM users";
//返回的结果集；结果集中封装了我们所有的查询结果
ResultSet resultSet = statement.executeQuery(sql);
while (resultSet.next()) {
System.out.println("id=" + resultSet.getObject("id"));
System.out.println("name=" + resultSet.getObject("NAME"));
System.out.println("password=" + resultSet.getObject("PASSWORD"));
System.out.println("email=" + resultSet.getObject("email"));
System.out.println("birthday=" + resultSet.getObject("birthday"));
System.out.println("====================================");
}
//6、释放链接；
resultSet.close();
statement.close();
connection.close();
}
}
编写步骤：
1、加载驱动。
2、连接数据库DriverManager
3、获得执行SQL的对象Statement
4、获得返回的结果集
5、释放资源
JDBC是怎么运行的，都是什么意思
1、 DriverManager
//DriverManager.registerDriver(new Driver()); 原来的写法
Class.forName("com.mysql.cj.jdbc.Driver");//固定写法(查看Driver底层)
//connection(关系关联)代表数据库
Connection connection = DriverManager.getConnection(url, username, password);
//connection 代表数据库
//事务自动提交
//事务提交
//事务回滚
connection.commit();
connection.rollback();
connection.setAutoCommit();
2、 URL
这里要注意的是：mysql8+ 的以上版本，要设置一个时区的配置？serverTimezone=UTC
String url = "jdbc:mysql://localhost:3306/jdbcstudy?useUnicode=true&characterEncoding=utf8&useSSL=true";
//mysql --3306
//协议://主机地址:端口号/数据库名?参数1&参数2&参数3
// oralce -- 1521
//jdbc:oracle:thin:@localhost:1521:sid
3、statement执行SQL的对象 prepareStatement()执行SQL的对象
Jdbc中的statement对象用于向数据库发送SQL语句，想完成对数据库的增删改查，只需要通过这个对象向数据库发送增删改查语句即可。
Statement对象的executeUpdate方法，用于向数据库发送增、删、改的sql语句，executeUpdate执行完后，将会返回一个整数（即增删改语句导致了数据库几行数据发生了变化)。
Statement.executeQuery方法用于向数据库发送查询语句，executeQuery方法返回代表查询结果的ResultSet对象,
statement执行sql的对象
statement.executeUpdate();//插入，删除，更新，都用这个，返回一个受影响的行数；
statement.execute(); //执行任意的SQL
statement.executeQuery();//查询操作返回resultSet
ResultSet结果集中封装了我们所有的查询结果
resultSet.getObject();//在不知道的情况下使用
//如果知道列的属性使用指定的类型
resultSet.getString();
resultSet.getInt();
resultSet.getBoolean();
....
resultSet.beforeFirst();//移动到最前面
resultSet.afterLast();//移动到最后面
resultSet.next();//移动到下一个数据
resultSet.previous();//移动到前一行
resultSet.absolute(row);//移动到指定行
4、释放链接
//6、释放链接；
resultSet.close();
statement.close();
connection.close();
封装JDBC：
我们的JDBC 程序步骤，大部分都是一样的
1、加载驱动。
2、连接数据库DriverManager
3、获得执行SQL的对象Statement
4、获得返回的结果集
5、释放资源
就一个执行的SQL不一样，这样的话，我们就可以封装成一个工具类；便于我们的操作。
提前创建一个db.properties 配置文件；
driver=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/(数据库名字)?useSSL=false&useUnicode=true&characterEncoding=utf8&serverTimezone=Asia/Shanghai
username=root
password=root
1：创建一个工具包：封装JDBC
public class jdbcUtils {
private static String driver = null;
private static String url = null;
private static String username = null;
private static String password = null;
static {
try {
//获得类的加载器，加载资源；
//这里是通过类获取反射对象，然后获取反射对象的类加载器，调用类加载器的获取资源的方法。一步一步来的
InputStream in = jdbcUtils.class.getClassLoader().getResourceAsStream("db.properties");
//把流读入到properties里面
Properties properties = new Properties();
properties.load(in);
driver = properties.getProperty("driver");
url = properties.getProperty("url");
username = properties.getProperty("username");
password = properties.getProperty("password");
//驱动只能加载一次
Class.forName(driver);
} catch (Exception e) {
e.printStackTrace();
}
}
//获取连接
public static Connection getConnection() throws SQLException {
return DriverManager.getConnection(url,username,password);
}
//释放连接资源
public static void release(Connection connection, Statement statement, ResultSet resultSet){
if (resultSet != null){
try {
resultSet.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if (statement != null){
try {
statement.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if (connection != null){
try {
connection.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
增删改，都是用的executeUpdate
增:
public class TestInsert {
public static void main(String[] args) {
Connection conn = null;
Statement stat = null;
ResultSet res = null;
try {
conn = jdbcUtils.getConnection();
//获取到sql的对象
stat = conn.createStatement();
String sql = "INSERT INTO users(id,`NAME`,`PASSWORD`,email,birthday)" +
"VALUES(4,'kuangshen','123456','123456@qq.com','2021-01-01')";
int i = stat.executeUpdate(sql);//增删改 执行完毕返回结果集
if (i > 0) {
System.out.println("插入成功!!");
}
} catch (SQLException e) {
e.printStackTrace();
} finally {
jdbcUtils.release(conn, stat, res);
}
}
删
public class TestDelete {
public static void main(String[] args) {
Connection conn = null;
Statement st = null;
ResultSet re = null;
try {
conn = jdbcUtils.getConnection();//获取数据库的连接
st = conn.createStatement(); //获得sql的执行对象
// 执行具体的sql语句
String sql = "DELETE FROM USERS WHERE ID = 4";
int i = st.executeUpdate(sql);
if (i > 0){
System.out.println("删除成功。");
}
} catch (SQLException e) {
e.printStackTrace();
}finally {
jdbcUtils.release(conn,st,re);
}
}
改
public static void main(String[] args) {
Connection conn = null;
Statement st = null;
ResultSet re = null;
try {
conn = jdbcUtils.getConnection();//获取数据库的连接
st = conn.createStatement(); //获得sql的执行对象
// 执行具体的sql语句
String sql = "update users set name = 'kuangshen',email = '123456@qq.com' where id = 1";
int i = st.executeUpdate(sql);//执行完毕返回结果集
if (i > 0){
System.out.println("插入成功。");
}
} catch (SQLException e) {
e.printStackTrace();
}finally {
jdbcUtils.release(conn,st,re);
}
}
查
public static void main(String[] args) {
Connection coon = null;
Statement stat = null;
ResultSet res = null;
try {
coon = jdbcUtils.getConnection();
stat = coon.createStatement();
//执行sql语句
String sql = "Select * from users where id = 1";
res = stat.executeQuery(sql);//执行完毕返回结果集
//如果只有一条数据（if），，如果有多条数据用（while）
while (res.next()) {
System.out.println(res.getString("NAME"));
}
} catch (SQLException e) {
e.printStackTrace();
} finally {
jdbcUtils.release(coon, stat, res);
}
}
小结：
1：我们可以看到，封装程一个类后，可以减少我们的代码，减少我们的代码冗余，提高程序的复用性。
2：增删改，executeUpdate。查：executeQuery
3：一定要关闭资源，切记。
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。
文章由极客之音整理，本文链接：https://www.bmabk.com/index.php/post/71903.html
