jdbc操作数据库

- - 一、导入mySql的驱动： com.mysql.jdbc.Driver
  - - - 1、Driver接口介绍
  - 二、配置URL
  - 三、创建数据库、数据表
  - - 1、创建student_management数据库
    - 2、创建student数据表
  - 四、写jdbc配置文件jdbc.properties
  - 五、创建对应Student类
  - 六、创建JDBCUtils类用来连接数据库以及资源的关闭
  - 七、创建StudentCRUD用来对student表进行CRUD操作
  - - 1、PreparedStatement介绍
    - 2、使用PreparedStatement 的好处
    - 3、使用PreparedStatement实现增、删、改、查操作

一、导入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 {
             //1.获取数据库的连接
            conn = JDBCUtils.getConnection();
            //2.获取PreparedStatement的实例 (或：预编译sql语句)
            ps = conn.prepareStatement(sql);
            //3.填充占位符
            for(int i = 0;i < args.length;i++){
                ps.setObject(i + 1, args[i]);
            }
            //4.执行sql语句
            ps.execute();
        } catch (Exception e) {
            e.printStackTrace();
        }finally{
        //5.关闭资源
            JDBCUtils.closeResource(conn, ps);
        }
    }


    
    public static  T getInstance(Class clazz, String sql, Object... args) {
        Connection conn = null;
        PreparedStatement ps = null;
        ResultSet rs = null;
        try {
             // 1.获取数据库连接
            conn = JDBCUtils.getConnection();
            // 2.预编译sql语句，得到PreparedStatement对象
            ps = conn.prepareStatement(sql);
            // 3.填充占位符
            for (int i = 0; i < args.length; i++) {
                ps.setObject(i + 1, args[i]);
            }
            // 4.执行executeQuery(),得到结果集：ResultSet
            rs = ps.executeQuery();
            // 5.得到结果集的元数据：ResultSetmetaData
            ResultSetmetaData rsmd = rs.getmetaData();
            // 6.1通过ResultSetmetaData得到columnCount,columnLabel；通过ResultSet得到列值
            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);
                    // 6.2使用反射，给对象的相应属性赋值
                    Field field = clazz.getDeclaredField(columnLabel);
                    field.setAccessible(true);
                    field.set(t, columnVal);
                }
                return t;
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            // 7.关闭资源
            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);
    }


}

jdbc操作数据库

Java相关栏目本月热门文章