一、导入mySql的驱动： com.mysql.jdbc.Driver
1、Driver接口介绍
- java.sql.Driver 接口是所有 JDBC驱动程序需要实现的接口。这个接口是提供给数据库厂商使用的，不同数据库厂商提供不同的实现。
- 在程序中不需要直接去访问实现了 Driver接口的类，而是由驱动程序管理器类(java.sql.DriverManager)去调用这些Driver实现。
- Oracle的驱动：oracle.jdbc.driver.OracleDriver
- mySql的驱动：com.mysql.jdbc.Driver
二、配置URL
- JDBC URL 用于标识一个被注册的驱动程序，驱动程序管理器通过这个 URL 选择正确的驱动程序，从而建立到 数据库的连接。
- JDBCURL的标准由三部分组成，各部分间用冒号分隔。
- jdbc:子协议:子名称
- 协议：JDBC URL中的协议总是jdbc
- 子协议：子协议用于标识一个数据库驱动程序
- 子名称：一种标识数据库的方法。子名称可以依不同的子协议而变化，用子名称的目的是为了定位数据库提供足够的信息。包含主机名(对应服务端的ip地址)，端口号，数据库名
三、创建数据库、数据表
1、创建student_management数据库
2、创建student数据表
CREATE TABLE `student` (
`id` int(10) PRIMARY KEY AUTO_INCREMENT ,
`name` varchar(255) NULL ,
`password` varchar(255) NULL
)
;
四、写jdbc配置文件jdbc.properties
user=root
password=000000
url=jdbc:mysql://localhost:3306/student_management?rewriteBatchedStatements=true
driverClass=com.mysql.jdbc.Driver
五、创建对应Student类
public class Student {
private Integer id;
private String name;
private String password;
public Student(String name, String password) {
this.name = name;
this.password = password;
}
public Student() {
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getPassword() {
return password;
}
public void setPassword(String password) {
this.password = password;
}
@Override
public String toString() {
return "Student{" +
"id='" + id + '\'' +
"name='" + name + '\'' +
", password='" + password + '\'' +
'}';
}
}
六、创建JDBCUtils类用来连接数据库以及资源的关闭
package util;
import java.io.InputStream;
import java.sql.*;
import java.util.Properties;
public class JDBCUtils {
public static Connection getConnection() throws Exception {
InputStream is = ClassLoader.getSystemClassLoader().getResourceAsStream("jdbc.properties");
Properties pros = new Properties();
pros.load(is);
String user = pros.getProperty("user");
String password = pros.getProperty("password");
String url = pros.getProperty("url");
String driverClass = pros.getProperty("driverClass");
Class.forName(driverClass);
Connection conn = DriverManager.getConnection(url, user, password);
return conn;
}
public static void closeResource(Connection conn, Statement ps){
try {
if (ps != null)
{ps.close();}
} catch (SQLException throwables) {
throwables.printStackTrace();
}
try {
if (conn != null)
{conn.close();}
} catch (SQLException throwables) {
throwables.printStackTrace();
}
}
public static void closeResource(Connection conn, Statement ps,ResultSet rs){
try {
if (ps != null)
{ps.close();}
} catch (SQLException throwables) {
throwables.printStackTrace();
}
try {
if (conn != null)
{ conn.close();}
} catch (SQLException throwables) {
throwables.printStackTrace();
}
try {
if (rs != null)
{conn.close();}
} catch (SQLException throwables) {
throwables.printStackTrace();
}
}
}
七、创建StudentCRUD用来对student表进行CRUD操作
1、PreparedStatement介绍
- 可以通过调用 Connection 对象的 preparedStatement(String sql) 方法获取
- PreparedStatement 对象 PreparedStatement 接口是 Statement 的子接口，它表示一条预编译过的SQL 语句
- PreparedStatement 对象所代表的 SQL 语句中的参数用问号(?)来表示，调用PreparedStatement 对象的 setXxx() 方法来设置这些参数. setXxx() 方法有两个参数，第一个参数是要设置的SQL 语句中的参数的索引(从 1 开始)，第二个是设置的 SQL 语句中的参数的值
2、使用PreparedStatement 的好处
- 代码的可读性和可维护性。
- PreparedStatement 能最大可能提高性能：
- DBServer会对预编译语句提供性能优化。因为预编译语句有可能被重复调用，所以语句在被DBServer的编译器编译后的执行代码被缓存下来，那么下次调用时只要是相同的预编译语句就不需要编译，只要将参数直接传入编译过的语句执行代码中就会得到执行。
- 在statement语句中,即使是相同操作但因为数据内容不一样,所以整个语句本身不能匹配,没有缓存语句的意义.事实是没有数据库会对普通语句编译后的执行代码缓存。这样每执行一次都要对传入的语句编译一次。
- (语法检查，语义检查，翻译成二进制命令，缓存)
- PreparedStatement 可以防止 SQL 注入
3、使用PreparedStatement实现增、删、改、查操作
import Student;
import org.junit.Test;
import JDBCUtils;
import java.lang.reflect.Field;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
public class StudentCRUD {
public static void update(String sql,Object ... args){
Connection conn = null;
PreparedStatement ps = null;
try {
conn = JDBCUtils.getConnection();
ps = conn.prepareStatement(sql);
for(int i = 0;i < args.length;i++){
ps.setObject(i + 1, args[i]);
}
ps.execute();
} catch (Exception e) {
e.printStackTrace();
}finally{
JDBCUtils.closeResource(conn, ps);
}
}
public static <T> T getInstance(Class<T> clazz, String sql, Object... args) {
Connection conn = null;
PreparedStatement ps = null;
ResultSet rs = null;
try {
conn = JDBCUtils.getConnection();
ps = conn.prepareStatement(sql);
for (int i = 0; i < args.length; i++) {
ps.setObject(i + 1, args[i]);
}
rs = ps.executeQuery();
ResultSetMetaData rsmd = rs.getMetaData();
int columnCount = rsmd.getColumnCount();
if (rs.next()) {
T t = clazz.newInstance();
for (int i = 0; i < columnCount; i++) {
Object columnVal = rs.getObject(i + 1);
String columnLabel = rsmd.getColumnLabel(i + 1);
Field field = clazz.getDeclaredField(columnLabel);
field.setAccessible(true);
field.set(t, columnVal);
}
return t;
}
} catch (Exception e) {
e.printStackTrace();
} finally {
JDBCUtils.closeResource(conn, ps, rs);
}
return null;
}
@Test
public void testInset(){
String sql = "insert into student(name,password)values(?,?)";
update(sql,"xiao","124124");
}
@Test
public void testUpdate(){
String sql = "delete from student where id = ?";
update(sql,1);
}
@Test
public void testUpdat(){
String sql = "update student set name = ? where id = ? ";
update(sql,"yang",1);
}
@Test
public void testSelect(){
String sql = "select id,name,password from student where id = ?;";
Student student = getInstance(Student.class, sql,1);
System.out.println(student);
}
@Test
public void testSelectForList(){
String sql = "select id,name,password from student;";
Student student = getInstance(Student.class, sql);
System.out.println(student);
}
}
|