- 1、JDBC介绍
- 2、编写JDBC程序
- 3.对象说明
- 3.1、**DriverManager类讲解**
- 3.2.**数据库URL讲解**
- 3.3 Connection类讲解
- 3.4 Statement类讲解
- 3.5 ResultSet类讲解
- 3.6 释放资源
- 4.statement对象
- 代码
- 使用statement对象完成对数据库的CRUD *** 作
- 5.PreparedStatement对象
- 避免SQL 注入
- 6.使用iDEA连接数据库
- 7.事务
- 代码测试
- 8.数据库连接池
- DBCP
- C3P0
- mysql-connector-java5.1.47下载网址：（在我的网盘里存储）
链接：https://pan.baidu.com/s/1fAQVqOniTU7O63T12A4Rkw?pwd=k4qn
提取码：k4qn
- 1.创建数据库
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','[email protected]','1980-12-04'),
(2,'lisi','123456','[email protected]','1981-12-04'),
(3,'wangwu','123456','[email protected]','1979-12-04');
- 2.IDEA创建一个普通项目
- 3.导入数据库驱动
- 4.数据库与java的连接
package com.kuang.lesson01;
import java.sql.*;
public class demo01 {
public static void main(String[] args) throws ClassNotFoundException, SQLException {
//1.加载驱动
Class.forName("com.mysql.jdbc.Driver");//推荐使用这种方式来加载驱动
//2.用户信息和url
String url ="jdbc:mysql://localhost:3306/jdbcStudy?useUnicode=true&characterEncoding=utf8&useSSL=true";
//连接的数据库时使用的用户名
String username = "root";
//连接的数据库时使用的密码
String password = "123456";
//3.连接成功，数据库对象 Connection 代表数据库
Connection conn = DriverManager.getConnection(url, username,password);
//4.执行SQL的对象， Statement 执行sql的对象
Statement statement=conn.createStatement();
//5.执行SQL的对象 去执行SQL，
String sql="SELECT * FROM users";
//向数据库发sql,并获取代表结果集的resultset
ResultSet rs=statement.executeQuery(sql);
//取出结果集的数据
while(rs.next()){
System.out.println("id=" + rs.getObject("id"));
System.out.println("name=" + rs.getObject("name"));
System.out.println("password=" + rs.getObject("password"));
System.out.println("email=" + rs.getObject("email"));
System.out.println("birthday=" + rs.getObject("birthday"));
}
//6.释放连接
rs.close();
statement.close();
conn.close();
}
}
3.3 Connection类讲解Oracle写法：jdbc:oracle:thin:@localhost:1521:sid
SqlServer写法：jdbc:microsoft:sqlserver://localhost:1433; DatabaseName=sid
MySql写法：jdbc:mysql://localhost:3306/sid
Jdbc程序中的Connection，它用于代表数据库的链接，Collection是数据库编程中最重要的一个对象，客户端与数据库所有交互都是通过connection对象完成的，这个对象的常用方法：
3.4 Statement类讲解
- createStatement()：创建向数据库发送sql的statement对象。
- prepareStatement(sql) ：创建向数据库发送预编译sql的PrepareSatement对象。
- setAutoCommit(boolean autoCommit)：设置事务是否自动提交。
- commit() ：在链接上提交事务。
- rollback() ：在此链接上回滚事务。
Jdbc程序中的Statement对象用于向数据库发送SQL语句， Statement对象常用方法：
3.5 ResultSet类讲解executeQuery(String sql) ：用于向数据发送查询语句。
executeUpdate(String sql)：用于向数据库发送insert、update或delete语句
execute(String sql)：用于向数据库发送任意sql语句
addBatch(String sql) ：把多条sql语句放到一个批处理中。
executeBatch()：向数据库发送一批sql语句执行。
Jdbc程序中的ResultSet用于代表Sql语句的执行结果。Resultset封装执行结果时，采用的类似于表格的方式。ResultSet 对象维护了一个指向表格数据行的游标，初始的时候，游标在第一行之前，调用ResultSet.next() 方法，可以使游标指向具体的数据行，进行调用方法获取该行的数据。
3.6 释放资源 4.statement对象dbc中的statement对象用于向数据库发送SQL语句，想完成对数据库的增删改查，只需要通过这个对象向数据库发送增删改查语句即可。
Statement对象的executeUpdate方法，用于向数据库发送增、删、改的sql语句，executeUpdate执行完后，将会返回一个整数（即增删改语句导致了数据库几行数据发生了变化）。
Statement.executeQuery方法用于向数据库发送查询语句，executeQuery方法返回代表查询结果的ResultSet对象。
1、新建一个 lesson02 的包
2、在src目录下创建一个db.properties文件，
driver=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/jdbcStudy?useUnicode=true&characterEncoding=utf8&useSSL=true
username =root
password =123456
在lesson02 下新建一个 utils 包，新建一个类 JdbcUtils
package com.kuang.lesson02.untils;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;
public class jbdcuntils {
private static String driver = null;
private static String url = null;
private static String username = null;
private static String password = null;
static{
try{
//读取db.properties文件中的数据库连接信息
InputStream in = jbdcuntils.class.getClassLoader().getResourceAsStream("db.properties");
Properties prop = new Properties();
prop.load(in);
//获取数据库连接驱动
driver = prop.getProperty("driver");
//获取数据库连接URL地址
url = prop.getProperty("url");
//获取数据库连接用户名
username = prop.getProperty("username");
//获取数据库连接密码
password = prop.getProperty("password");
//加载数据库驱动
Class.forName(driver);
}catch (Exception e) {
throw new ExceptionInInitializerError(e);
}
}
// 获取数据库连接对象
public static Connection getConnection() throws SQLException{
return DriverManager.getConnection(url, username,password);
}
// 释放资源，要释放的资源包括Connection数据库连接对象，负责执行SQL命令的Statement
//对象，存储查询结果的ResultSet对象
public static void release(Connection conn,Statement st,ResultSet rs){
if(rs!=null){
try{
//关闭存储查询结果的ResultSet对象
rs.close();
}catch (Exception e) {
e.printStackTrace();
}
rs = null;
}
if(st!=null){
try{
//关闭负责执行SQL命令的Statement对象
st.close();
}catch (Exception e) {
e.printStackTrace();
}
}
if(conn!=null){
try{
//关闭Connection数据库连接对象
conn.close();
}catch (Exception e) {
e.printStackTrace();
}
}
}
}
- 1、插入一条数据
package com.kuang.lesson02;
import com.kuang.lesson02.untils.jbdcuntils;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.Statement;
public class demo01 {
public static void main(String[] args) {
Connection conn = null;
Statement st = null;
ResultSet rs = null;
try{
//获取一个数据库连接
conn = jbdcuntils.getConnection();
//通过conn对象获取负责执行SQL命令的Statement对象
st = conn.createStatement();
//要执行的SQL命令
String sql = "insert into users(id,name,password,email,birthday) " + "values(4,'kuangshen','123','[email protected]','2020-01-01')";
//执行插入 *** 作，executeUpdate方法返回成功的条数
int num = st.executeUpdate(sql);
if(num>0){
System.out.println("插入成功！！");
}
}catch (Exception e) {
e.printStackTrace();
}finally{
//SQL执行完成之后释放相关资源
jbdcuntils.release(conn, st, rs);
}
}
}
- 2、删除一条数据
- SQL 注入问题
通过巧妙的技巧来拼接字符串，造成SQL短路，从而获取数据库数据
PreperedStatement是Statement的子类，它的实例对象可以通过调用
Connection.preparedStatement()方法获得，相对于Statement对象而言：PreperedStatement可以避免SQL注入的问题。
Statement会使数据库频繁编译SQL，可能造成数据库缓冲区溢出。
PreparedStatement可对SQL进行预编译，从而提高数据库的执行效率。并且PreperedStatement对于sql中的参数，允许使用占位符的形式进行替换，简化sql语句的编写。
- 使用PreparedStatement对象完成对数据库的CRUD *** 作
- 1.插入一条数据
package com.kuang.lesson02;
import com.kuang.lesson02.untils.jbdcuntils;
import java.sql.Connection;
import java.util.Date;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
public class demo02 {
public static void main(String[] args) {
Connection conn = null;
PreparedStatement st = null;
ResultSet rs = null;
try{
//获取一个数据库连接
conn = jbdcuntils.getConnection();
//要执行的SQL命令，SQL中的参数使用?作为占位符
String sql = "insert into users(id,name,password,email,birthday) values(?,?,?,?,?)";
//通过conn对象获取负责执行SQL命令的prepareStatement对象
st = conn.prepareStatement(sql);
//为SQL语句中的参数赋值，注意，索引是从1开始的
st.setInt(1, 5);//id是int类型的
st.setString(2, "kuangshen");//name是varchar(字符串类型)
st.setString(3, "123");//password是varchar(字符串类型)
st.setString(4, "[email protected]");//email是varchar(字符串类型)
st.setDate(5, new java.sql.Date(new Date().getTime()));//birthday是date类型
//执行插入 *** 作，executeUpdate方法返回成功的条数
int num = st.executeUpdate();
if(num>0){
System.out.println("插入成功！！");
}
}catch (Exception e) {
e.printStackTrace();
}finally{
//SQL执行完成之后释放相关资源
jbdcuntils.release(conn, st, rs);
}
}
}
/*创建账户表*/
CREATE TABLE account(
id INT PRIMARY KEY AUTO_INCREMENT,
NAME VARCHAR(40),
money FLOAT
);
/*插入测试数据*/
insert into account(name,money) values('A',1000);
insert into account(name,money) values('B',1000);
insert into account(name,money) values('C',1000);
当Jdbc程序向数据库获得一个Connection对象时，默认情况下这个Connection对象会自动向数据库提交在它上面发送的SQL语句。若想关闭这种默认提交方式，让多条SQL在一个事务中执行，可使用下列的JDBC控制事务语句
Connection.setAutoCommit(false); //开启事务(start transaction)
Connection.rollback(); //回滚事务(rollback)
Connection.commit(); //提交事务(commit)
- 开源数据源实现
DBCPDBCP
C3P0
Druid:阿里巴巴
Commons-dbcp.jar：连接池的实现
Commons-pool.jar：连接池实现的依赖库
C3P0测试：
1、导入相关jar包
2、在类目录下加入dbcp的配置文件：dbcpconfig.properties
3、编写工具类 JdbcUtils_DBCP
4.测试类
测试
1、导入相关jar包
2、在类目录下加入C3P0的配置文件：c3p0-config.xml
3、创建工具类JdbcUtils_C3P0
欢迎分享，转载请注明来源：内存溢出
微信扫一扫
支付宝扫一扫
评论列表（0条）