Java jdbc相关

JDBC:java database connectivity --- SUN公司提供的一套操作数据库的标准规范。

JDBC与数据库驱动的关系：接口与实现的关系。

JDBC规范：

　　DriverManager(类):用于注册驱动

　　Connection(接口): 表示与数据库创建的连接

　　Statement(接口): 操作数据库sql语句的对象

　　ResultSet(接口): 结果集或一张虚拟表

实现JDBC操作

              //1、注册驱动

              //2、创建连接

              //3、得到执行sql语句的Statement对象

              //4、执行sql语句，并返回结果

              //5、处理结果

              //6、关闭资源

一  java.sql.DriverManager类:创建连接

　　① 注册驱动

　　　　DriverManager.registerDiver(new com.mysql.jdbc.Driver());　

　　　　//不建议使用,原因: 导致驱动被注册两次 , 强烈依赖数据库的驱动jar

　　　　解决办法:

　　　　Class.forName("com.mysql.jdbc.Driver);

　　② 与数据库建立连接

　　　static Connection getConnection(String url, String user, String password) 试图建立到给定数据库 URL 的连接。

　　　　conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/zzzz","root","pass");

二  java.sql.Connection 接口 是一个连接

　　接口的实现在数据库驱动中, 所有与数据库交互都是基于连接对象的.

　　Statement createStatement(); //创建操作sql语句的对象

　　Statement stmt = conn.createStatement();

三  java.sql.Statement 接口 :操作sql语句,并返回相应结果的对象

　　接口的实现在数据库驱动中, 用于执行静态sql语句并返回它所生成结果的对象

　　ResultSet  executeQuery(String sql) 根据查询语句返回结果集。只能执行select语句。

 　　int executeUpdate(String sql) 根据执行的DML（insert update delete）语句，返回受影响的行数。

　　boolean execute(String sql)  此方法可以执行任意sql语句。返回boolean值，表示是否返回ResultSet结果集。仅当执行select语句，且有返回结果时返回true, 其它语句都返回false;

四  java.sql.ResultSet 接口 : 结果集(客户端存表数据的对象)

jdbc初试

package com.javaDemo.jdbcDemo;

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

//使用JDBC技术实现查询数据库数据,并显示在控制台中
public class Demo1 {

    public static void main(String[] args) throws Exception {
        Connection conn = null;
        Statement stmt = null;
        ResultSet rs = null;
        try {
            Class.forName("com.mysql.jdbc.Driver");
            conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/zzzz","root","");
            stmt = conn.createStatement();
            rs = stmt.executeQuery("select * from users");
            //处理结果
            while(rs.next()) {
                System.out.println(rs.getObject(1));
                System.out.println(rs.getObject(2));
                System.out.println(rs.getObject(3));
                System.out.println(rs.getObject(4));
                System.out.println(rs.getObject(5));
                System.out.println("----------------");
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {                //关闭资源
            if (rs!=null) {
                try {
                    rs.close();
                } catch (Exception e) {
                    e.printStackTrace();
                }
　　　　　　　　　　　rs=null;
            }
            if (stmt!=null) {
                try {
                    stmt.close();
                } catch (Exception e) {
                    e.printStackTrace();
                }
                stmt = null;
            }
            if (conn!=null) {
                try {
                    conn.close();
                } catch (Exception e) {
                    e.printStackTrace();
                }
                conn=null;
            }
        }
    }

}
        

jdbc之CRUD(增删改查)
1.User.java

package com.javaDemo.crud;

public class User {
    private String user_id;
    private String first_name;
    private String last_name;
    public User() {
        super();
    }
    public User(String user_id, String first_name, String last_name) {
        this.user_id = user_id;
        this.first_name = first_name;
        this.last_name = last_name;
    }
    public String getUser_id() {
        return user_id;
    }
    public void setUser_id(String user_id) {
        this.user_id = user_id;
    }
    public String getFirst_name() {
        return first_name;
    }
    public void setFirst_name(String first_name) {
        this.first_name = first_name;
    }
    public String getLast_name() {
        return last_name;
    }
    public void setLast_name(String last_name) {
        this.last_name = last_name;
    }
    @Override
    public String toString() {
        // TODO Auto-generated method stub
        return user_id + "---" +first_name +"--"+last_name;
    }
    
}

2.dbinfo.properties

3.DBUtils.java

package com.javaDemo.util;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ResourceBundle;

public class DBUtils {
    private static String driverClass;
    private static String url;
    private static String username;
    private static String password;
    static {
        //此对象是用于加载properties文件数据的
        ResourceBundle rb = ResourceBundle.getBundle("dbinfo");
        driverClass = rb.getString("driverClass");
        url = rb.getString("url");
        username = rb.getString("username");
        password = rb.getString("password");
        try {
            Class.forName(driverClass);
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        }
    }
    //得到连接的方法
    public static Connection getConnection() throws Exception {
        return DriverManager.getConnection(url,username,password);
    }
    
    //关闭资源的方法
    public static void closeAll(ResultSet rs,Statement stmt,Connection conn) {
        if (rs!=null) {
            try {
                rs.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
            rs = null;
        }
        if (stmt!=null) {
            try {
                stmt.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
            stmt=null;
        }
        if (conn!=null) {
            try {
                conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
            conn=null;
        }
    }
}

4.testCRUD.java

package com.javaDemo.crud;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;

import org.junit.Test;

import com.itheima.util.DBUtils;

public class TestCRUD {
    @Test
    public void testSelect() {
        Connection conn = null;
        Statement stmt = null;
        ResultSet rs = null;
        try {
            conn = DBUtils.getConnection();
            stmt = conn.createStatement();
            rs = stmt.executeQuery("select * from users;");
            List<User> list = new ArrayList<User>();
            while (rs.next()) {
                User u = new User();
                u.setUser_id(rs.getString(1));
                u.setFirst_name(rs.getString(2));
                u.setLast_name(rs.getString(3));
                list.add(u);
            }
            for (User user : list) {
                System.out.println(user);
                System.out.println("-----------");
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            DBUtils.closeAll(rs, stmt, conn);
        }
        
    }
    
    
    @Test
    public void testInsert() {
        Connection conn = null;
        Statement stmt = null;
        
        try {
            conn = DBUtils.getConnection();
            stmt = conn.createStatement();
            int i = stmt.executeUpdate("INSERT INTO users VALUES(6,'hack','ME','abc','5555','2017',' 2016-11-25 12:54:34','12345');");
            if (i>0) {
                System.out.println("success!");
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            DBUtils.closeAll(null, stmt, conn);
        }
        
    }
    
    
    @Test
    public void testDelete() {
        Connection conn = null;
        Statement stmt = null;
        
        try {
            conn = DBUtils.getConnection();
            stmt = conn.createStatement();
            int i = stmt.executeUpdate("DELETE FROM users WHERE user_id=6;");
            if (i>0) {
                System.out.println("success!");
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            DBUtils.closeAll(null, stmt, conn);
        }
        
    }
}

 *************

为了避免sql注入漏洞,需要使用PreparedStatement来代替Statement.

PreparedStatement的第一次执行消耗是很高的. 它的性能体现在后面的重复执行