5-JDBC資料庫開發入門

課時1-2 1.什麼是JDBC

JDBC 資料庫通路規範

應用程式 <-> JDBC <-> MySQL驅動 <-> MySQL
                 <-> Oracle驅動 <-> Oracle

導入jar包

加載驅動 Class.forName(‘類名’)

給出url、username、password

使用DriverManager類得到Connection類

maven導入依賴

<dependencies>
    <dependency>
        <groupId>mysql</groupId>
        <artifactId>mysql-connector-java</artifactId>
        <version>8.0.18</version>
    </dependency>
</dependencies>

連接配接示例

import java.sql.Connection;
import java.sql.DriverManager;

class Demo {

    // MySQL >= 8.0 配置參數
    private static final String JDBC_DRIVER = "com.mysql.cj.jdbc.Driver";
    private static final String DB_URL = "jdbc:mysql://localhost:3306/data";
    private static final String USER = "root";
    private static final String PASSWORD = "123456";


    public static void main(String[] args) throws Exception {
        // 注冊 JDBC 驅動
        Class.forName(JDBC_DRIVER);

        // 等效于
        // com.mysql.cj.jdbc.Driver driver = new com.mysql.cj.jdbc.Driver();
        // DriverManager.registerDriver(driver);

        // 打開連結
        Connection conn = DriverManager.getConnection(DB_URL, USER, PASSWORD);
        
        // 關閉連結
        conn.close();

    }

}

所有的java.sql.Driver實作類，都提供了static代碼塊，

塊内代碼把自己注冊到DriverManager中

jdbc4.0之後每個驅動jar包中，在META-INF/services目錄下提供了一個java.sql.Driver檔案

内容就是該接口的實作類名稱

課時3 3.JDBC完成增、删、改、查

1、增、删、改

// 發送DML, DDL
int Statement.executeUpdate(String sql);

代碼示例

// 注冊 JDBC 驅動
Class.forName(JDBC_DRIVER);

// 打開連結
Connection conn = DriverManager.getConnection(DB_URL, USER, PASSWORD);
Statement statement = conn.createStatement();

// 增删改
// String sql = "insert into student(sname) values('陸小鳳')";
// String sql = "update student set sname='花無缺' where sid=4";
String sql = "delete from student where sid=4";

int ret = statement.executeUpdate(sql);
System.out.println(ret);

// 關閉連結
conn.close();

2、查詢

ResultSet executeQuery(String querySql);
boolean ResultSet.next();

// 擷取列資料
ResultSet.getString()
ResultSet.getObject()
ResultSet.getInt()
ResultSet.getDouble()

行光标

beforeFirst <- 預設光标位置
first
last
AfterLast

// 打開連結
Connection conn = DriverManager.getConnection(DB_URL, USER, PASSWORD);
Statement statement = conn.createStatement();

// 查詢
String sql = "select * from student";

ResultSet ret = statement.executeQuery(sql);
while (ret.next()){
    // 通過列序号擷取
    int uid = ret.getInt(1);
    // 通過列名稱擷取
    String name = ret.getString("sname");
    System.out.println(uid + ", " + name);
}

// 關閉資源
ret.close();
statement.close();
conn.close();

課時4 4.JDBC之代碼規範化

// 定義
try{
    // 執行個體化
}
finally{
    // 關閉資源
}

課時5 5.結果集光标與中繼資料

JBDC主要的類

DriverManager

Connection conn = DriverManager.getConnection(DB_URL, USER, PASSWORD);

Statement statement = conn.createStatement(); 
    int executeUpdate(String sql)    // 執行增、删、改
    ResultSet executeQuery(String sql)  // 執行查詢
    boolean execute(String sql)         // 執行增、删、改、查

ResultSet滾動結果集

一個二維表格，内部維護了一個行光标（遊标）

next() // 最常用

beforeFirst()
afterLast()
first()
last()
getRow()
absolute()
relative()

isBeforeFirst()
isAfterLast()
isFirst()
isLast()

中繼資料

// 中繼資料 
ResultSetMetaData ResultSet.getMetaData()

// 擷取結果集列數
int ResultSetMetaData.getColumnCount()

// 擷取指定列的列名
String ResultSetMetaData.getColumnName(int colIndex)

課時6 6.結果集的特性（是否可滾動、是否敏感、是否可更新）

确定結果集特性

1、是否可滾動

2、是否敏感

3、是否可更新

// 不滾動, 不敏感，不可更新
Statement createStatement()

// 滾動支援
Statement createStatement(int resultSetType, int resultSetConcurrency)        

resultSetType:
ResultSet.TYPE_FORWARD_ONLY  // 不滾動
ResultSet.TYPE_SCROLL_INSENSITIVE // 滾動，不随資料庫變化而變化
ResultSet.TYPE_SCROLL_SENSITIVE // 滾動，不随資料庫變化而變化

resultSetConcurrency // 是否通過修改結果集二反向影響資料庫
ResultSet.CONCUR_READ_ONLY // 結果集隻讀 
ResultSet.CONCUR_UPDATABLE // 結果集可更新

課時7 7.PreparedStatement的用法

PreparedStatement是Statement子接口

1、防止SQL注入攻擊

2、提高代碼可讀性，可維護性

3、提高效率

// 打開連結
Connection conn = DriverManager.getConnection(DB_URL, USER, PASSWORD);

// 使用預處理查詢， 使用？占位
String sql = "select * from student where sid = ?";
PreparedStatement statement = conn.prepareStatement(sql);

// 為參數指派
statement.setInt(1, 1);

// 擷取資料
ResultSet ret = statement.executeQuery();
while (ret.next()){
    String name = ret.getString("sname");
    System.out.println(name);
}

// 關閉資源
ret.close();
statement.close();
conn.close();

課時8 8.預處理的原理

伺服器工作：

（1）校驗：sql語句的文法

（2）編譯：為一個與函數相似的東西

（3）執行：調用函數

PreparedStatement

（1）先将sql發給資料庫，資料庫先進行校驗

（2）執行的時候隻發送參數

課時9 9.mysql的預編譯功能預設是關閉的

prepare myfun from 'select * from student where sid = ?'
set @uid=1
execute myfun using @uid

設定連接配接參數：

useServerPrepStmts=true

cachePrepStmts=true

DB_URL = "jdbc:mysql://localhost:3306/data?useServerPrepStmts=true&cachePrepStmts=true";

課時10 10.JdbcUtils1.0小工具

JdbcUtils.java

package util;

import java.io.IOException;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.util.Properties;

public class JdbcUtils {
    // 配置檔案路徑
    private static String dbconfig = "dbconfig.properties";

    private static Properties prop = null;

    // 靜态代碼塊隻執行一次
    static {
        // 初始化資料庫配置參數
        try {
            InputStream in = JdbcUtils.class.getClassLoader().getResourceAsStream(dbconfig);
            prop = new Properties();
            prop.load(in);
        } catch (IOException e) {
            throw new RuntimeException(e);
        }

        // 加載驅動
        try{
            Class.forName(prop.getProperty("driver"));
        } catch (ClassNotFoundException e) {
            throw new RuntimeException(e);
        }
    }

    public static Connection getConnection() throws SQLException {
        return DriverManager.getConnection(
                prop.getProperty("url"),
                prop.getProperty("username"),
                prop.getProperty("password")
        );
    }

    public static void main(String[] args) throws SQLException {
        Connection conn = getConnection();
        System.out.println(conn);
    }

}

dbconfig.properties

driver=com.mysql.cj.jdbc.Driver
url=jdbc:mysql://localhost:3306/data
username=root
password=123456

課時11 11.面向接口程式設計

DAO模式

data access object

寫一個類，把通路資料庫的代碼封裝起來

DAO在資料庫與業務邏輯（service）之間

實體域，即操作的對象

DAO模式步驟

（1）提供一個DAO接口

（2）提供一個DAO接口的實作類

（3）在編寫一個DAO工廠，Service通過工廠來擷取DAO實作

daoconfig.properties

UserDaoClassName=UserDaoImpl

UserDao.java

public interface UserDao {
}

UserDaoImpl.java

public class UserDaoImpl implements UserDao{
}

DaoFactory.java

import java.io.IOException;
import java.io.InputStream;
import java.util.Properties;

public class DaoFactory {
    // 配置檔案路徑
    private static String dbconfig = "daoconfig.properties";

    private static Properties prop = null;

    // 靜态代碼塊隻執行一次
    static {
        // 初始化資料庫配置參數
        try {
            InputStream in = DaoFactory.class.getClassLoader().getResourceAsStream(dbconfig);
            prop = new Properties();
            prop.load(in);
        } catch (IOException e) {
            throw new RuntimeException(e);
        }
    }

    /**
     * 傳回一個UserDao的具體實作類
     */
    public static UserDao getUserDao() {
        String daoClassName = prop.getProperty("UserDaoClassName");

        // 通過反射建立實作類的對象
        try {
            Class Clazz = Class.forName(daoClassName);
            return (UserDao) Clazz.newInstance();
        } catch (Exception e) {
            throw new RuntimeException(e);
        }
    }

}

課時12 12.修改案例，其中dao層為jdbc

User.java

public class User {
    private String username;
    private int age;

    public String getUsername() {
        return username;
    }

    public int getAge() {
        return age;
    }

    public void setUsername(String username) {
        this.username = username;
    }

    public void setAge(int age) {
        this.age = age;
    }

    @Override
    public String toString() {
        return "User{" +
                "username='" + username + '\'' +
                ", age=" + age +
                '}';
    }
}

UserDaoClassName=UserDaoImpl

public interface UserDao {
    public void addUser(User user);
    public User getUserByUsername(String username);
}

import util.JdbcUtils;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

/**
 * create table user(
 * id int primary key auto_increment,
 * username varchar(50),
 * age int
 * )
 */
public class UserDaoImpl implements UserDao {

    /**
     * ORM 對象關系映射
     * @param user
     */
    @Override
    public void addUser(User user) {
        Connection conn = null;
        PreparedStatement statement = null;

        try {
            // 得到連接配接
            conn = JdbcUtils.getConnection();
            String sql = "insert into user(username, age) values(?, ?)";

            // 準備模闆
            statement = conn.prepareStatement(sql);

            // 指派
            statement.setString(1, user.getUsername());
            statement.setInt(2, user.getAge());

            // 執行
            statement.executeUpdate();
        } catch (Exception e) {
            throw new RuntimeException(e);
        } finally {
            try {
                if (statement != null) {
                    statement.close();
                }
                if (conn != null) {
                    conn.close();
                }
            } catch (SQLException e) {

            }
        }
    }

    @Override
    public User getUserByUsername(String username) {

        Connection conn = null;
        PreparedStatement statement = null;

        try {
            // 得到連接配接
            conn = JdbcUtils.getConnection();
            String sql = "select * from user where username = ? limit 1";

            // 準備模闆
            statement = conn.prepareStatement(sql);

            // 指派
            statement.setString(1, username);

            // 執行
            ResultSet resultSet = statement.executeQuery();
            if(resultSet.next()){
                User user = new User();
                user.setUsername(resultSet.getString("username"));
                user.setAge(resultSet.getInt("age"));
                return user;
            }
            else{
                return null;
            }
        } catch (Exception e) {
            throw new RuntimeException(e);
        } finally {
            try {
                if (statement != null) {
                    statement.close();
                }
                if (conn != null) {
                    conn.close();
                }
            } catch (SQLException e) {

            }
        }
    }
}

import java.io.IOException;
import java.io.InputStream;
import java.util.Properties;

public class DaoFactory {
    // 配置檔案路徑
    private static String dbconfig = "daoconfig.properties";

    private static Properties prop = null;

    // 靜态代碼塊隻執行一次
    static {
        // 初始化資料庫配置參數
        try {
            InputStream in = DaoFactory.class.getClassLoader().getResourceAsStream(dbconfig);
            prop = new Properties();
            prop.load(in);
        } catch (IOException e) {
            throw new RuntimeException(e);
        }
    }

    /**
     * 傳回一個UserDao的具體實作類
     */
    public static UserDao getUserDao() {
        String daoClassName = prop.getProperty("UserDaoClassName");

        // 通過反射建立實作類的對象
        try {
            Class Clazz = Class.forName(daoClassName);
            return (UserDao) Clazz.newInstance();
        } catch (Exception e) {
            throw new RuntimeException(e);
        }
    }

}

Service.java

// 添加測試
UserDao userDao = DaoFactory.getUserDao();

User user = new User();
user.setUsername("小明");
user.setAge(23);
userDao.addUser(user);

// 查詢測試
User user1 = userDao.getUserByUsername("小明");
System.out.println(user1);

課時13 13.util包下的Date與sql包下的時間類型之間的轉換

Data -> java.sql.Data

Time -> java.sql.Time

Timestamp -> java.sql.Timestamp

領域對象中所有屬性不能出現java.sql包内容

繼承關系

java.util.Date
    -java.sql.Date

父類轉子類：util.Data -> sql.Date、Time、Timestamp

java.util.Date UtilDate = new java.util.Date();
long longDate = UtilDate.getTime();
java.sql.Date sqlData = new java.sql.Date(longDate);

子類轉父類：sql.Date、Time、Timestamp -> util.Data

java.util.Date UtilDate = new java.sql.Date(System.currentTimeMillis());

課時14 14.大資料

可以将檔案存入MySQL

my.ini配置

max_allowed_packet=10485760

課時15 15.批處理

批處理隻針對更新（增，删，改）

一次向伺服器發送多條sql語句

開啟批處理參數

rewriteBatchedStatements=true

driver=com.mysql.cj.jdbc.Driver
url=jdbc:mysql://localhost:3306/data?rewriteBatchedStatements=true
username=root
password=123456

import util.JdbcUtils;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;

class Demo {
    public static void main(String[] args) throws SQLException {
        Connection conn = JdbcUtils.getConnection();
        String sql = "insert into user(username)values(?)";
        PreparedStatement statement = conn.prepareStatement(sql);

        for(int i=0; i<10000; i++){
            statement.setString(1, "name" + i);
            statement.addBatch(); // 裝箱
        }

        long start = System.currentTimeMillis();
        statement.executeBatch(); // 送出資料
        long end = System.currentTimeMillis();
        System.out.println(end - start); // 107
    }
}

Java學習路線-43：JDBC資料庫開發入門5-JDBC資料庫開發入門

5-JDBC資料庫開發入門

課時1-2 1.什麼是JDBC

課時3 3.JDBC完成增、删、改、查

課時4 4.JDBC之代碼規範化

課時5 5.結果集光标與中繼資料

課時6 6.結果集的特性（是否可滾動、是否敏感、是否可更新）

課時7 7.PreparedStatement的用法

課時8 8.預處理的原理

課時9 9.mysql的預編譯功能預設是關閉的

課時10 10.JdbcUtils1.0小工具

課時11 11.面向接口程式設計

課時12 12.修改案例，其中dao層為jdbc

課時13 13.util包下的Date與sql包下的時間類型之間的轉換

課時14 14.大資料

課時15 15.批處理

繼續閱讀

spark/scala關于【資源檔案】加載方法概述外部檔案加載方案測試資源檔案打包入jar包中小結

NOSQL安全攻擊

mybatis_入門程式Mybatis入門

mysql使用source指令導入.sql檔案

maven No compiler is provided in this environment. Perhaps you are running on a JRE rather than a J

AOP程式設計_Android優雅權限架構(1)概念基礎，2021金三銀四前言正文大綱正文

登入plsql 報錯 the account is locked --使用者被鎖

sqlServer根據經緯查距離

Effective Java 8:通用程式設計

SequoiaDB巨杉資料庫C++驅動概述

OOM三種類型

工廠模式-三種類型

【遞歸】高效率求2的n次幂

win10本地scala和spark安裝安裝scala安裝spark

scala (3) Function 和 Method

Opendaylight課堂之深度剖析toaster（一）