JDBC 数据库查询 更新

JDBC 驱动相当于是已经帮助实现了很多的接口，可以直接使用封装好的函数。

前提：将数据库的驱动导入到构建路径当中。

a. 注册驱动。

b. 获取与数据库的连接。

c. 创建代表SQL语句的对象。

d. 执行SQL语句。

e.释放占用的资源。

查询步骤：

1. 注册驱动程序并建立链接。

2. 执行语句并保存在结果集当中。

3. 资源回收。

package com.yueling.jdbc;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;

public class JDBCTest {
public static void main(String[] args) {
String sql = "select * from tbl_user";
Connection conn = null;//当前数据库链接
Statement st = null;//向数据库发送语句
ResultSet rs = null;//结果集

try {
//不推荐，因为依赖具体驱动，而且会导致驱动注册两遍（因为静态代码块儿已经注册过）。
//DriverManager.registerDriver(new com.mysql.jdbc.Driver());
Class.forName("com.mysql.jdbc.Driver");//注册驱动程序，推荐，依赖某个字符串而不是类
// 不同的数据库url写法不相同，遵从相关的协议
conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/jsp_db","root","admin");//或是利用Properties设置属性组。
//创建向数据库发送sql的statement对象
st = conn.createStatement();
rs = st.executeQuery(sql);//用于执行query语句，返回 ResultSet
while(rs.next()){
System.out.println(rs.getInt("id") + "  ");
System.out.println(rs.getString("name") + "  ");
System.out.println(rs.getString("password") + "  ");
System.out.println(rs.getString("email") + "  ");
}

} catch (Exception e) {
e.printStackTrace();
} finally{
try {
rs.close();
} catch (Exception e2) {
e2.printStackTrace();
}
try {
st.close();
} catch (Exception e3) {
e3.printStackTrace();
}
try {
conn.close();
} catch (Exception e4) {
e4.printStackTrace();
}
}
}
}

数据库更新

package com.yueling.jdbc;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;

public class JDBCTest {
public static Connection getConnection(){
Connection conn= null;
try {
Class.forName("com.mysql.jdbc.Driver");
conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/jsp_db","root","admin");
} catch (Exception e) {
e.printStackTrace();
}
return conn;
}

public static void insert(){
Connection conn = getConnection();
try {
String sql = "INSERT INTO tbl_user(name, password, email)" +
"VALUES('TOM', '1234567', 'tom@qq.com')";
Statement st = conn.createStatement();
int count = st.executeUpdate(sql);//执行除了select的语句，返回执行的条数
System.out.println("向用户表中插入了" + count + " 条记录");
conn.close();
} catch (Exception e) {
e.printStackTrace();
}
}

public static void update(){
Connection conn = getConnection();
try {
String sql = "UPDATE tbl_user SET email = 'yueling@qq.com' WHERE name = 'TOM'";
Statement st = conn.createStatement();
int count = st.executeUpdate(sql);//返回影响的条数
System.out.println("向用户表中更新了" + count + " 条记录");
conn.close();
} catch (Exception e) {
e.printStackTrace();
}
}

public static void delete(){
Connection conn = getConnection();
try {
String sql = "DELETE FROM tbl_user WHERE name = 'TOM'";
Statement st = conn.createStatement();
int count = st.executeUpdate(sql);//返回影响的条数
System.out.println("向用户表中删除了" + count + " 条记录");
conn.close();
} catch (Exception e) {
e.printStackTrace();
}
}