1.注册驱动
Class.forName("com.mysql.jdbc.Driver");
2. 建立连接
// 建立连接 参数1：协议+访问的数据库名 参数2：用户名 参数3：数据库密码
conn=(Connection) DriverManager.getConnection("jdbc:mysql://localhost/test", "root", "123456");
3.创建Statement
// 创建statement ，跟数据库打交道，一定需要这个对象
statement= conn.createStatement();
4. 执行sql 语句 得到ResultSet
// 执行sql
String sql="select * from t_stu";
rSet=statement.executeQuery(sql);
4. 遍历得到结果
//遍历查询每一条数据
while (rSet.next()) {
int id=rSet.getInt("id");
String name=rSet.getString("name");
int age=rSet.getInt("age");
System.out.println("id="+id+"name="+name+"age="+age);
}
5.释放资源
rSet.close();
connection.close();
statement.close();
6.jdbc工具类构建
6.1 防止驱动二次注册
Class.forName("com.mysql.jdbc.Driver");
6.2 使用properties配置文件
1.先在src目录下生成一个jdbc.properties 文件 内容如下:
driverClass=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost/test
name=root
password=123456
- 在工具类中 使用静态代码块 读取属性
static {
try {
// 创建一个属性配置对象
Properties properties = new Properties();
InputStream is = new FileInputStream("jdbc.properties");//对应文件位于项目的跟目录
//使用类加载
//InputStream is=JDBCUtil.class.getClassLoader().getResourceAsStream("jdbc.properties");//对应文件位于src目录下
// 导入输入流
properties.load(is);
// 读取属性
driverClass = properties.getProperty("driverClass");
url = properties.getProperty("url");
name = properties.getProperty("name");
password = properties.getProperty("password");
} catch (IOException e) {
e.printStackTrace();
}
}
7.数据库CRUD
- insert
INSERT INTO t_stu (NAME,age)VALUES ("张三",20);
// 连接对象
connection = JDBCUtil.getConn();
// 根据连接对象 得到Statement
statement = connection.createStatement();
// 执行添加
String sql = "insert into t_stu value(null,'aobama',59)";
//影响的行数 如果result大于0 表示添加成功
int result = statement.executeUpdate(sql);
if (result>0) {
System.out.println("添加成功");
}else {
System.out.println("添加失败");
}
- delete
DELETE FROM t_stu WHERE id=3;
// 连接对象
connection = JDBCUtil.getConn();
// 根据连接对象 得到Statement
statement = connection.createStatement();
// 执行添加
String sql = "delete from t_stu where name='aobama' ";
//影响的行数 如果result大于0 表示添加成功
int result = statement.executeUpdate(sql);
if (result>0) {
System.out.println("删除成功");
}else {
System.out.println("删除失败");
}
- query
SELECT *FROM t_stu
// 连接对象
connection = JDBCUtil.getConn();
// 根据连接对象 得到Statement
statement = connection.createStatement();
// 执行sql语句 返回ResultSet
String sql = "select * from t_stu";
rSet = statement.executeQuery(sql);
// 遍历结果集
while (rSet.next()) {
String name = rSet.getString("name");
int age = rSet.getInt("age");
System.out.println("name====" + name + "----age===" + age);
}
- update
UPDATE t_stu SET age=38 WHERE id=1;
