數(shù)據(jù)庫技術(shù)五:數(shù)據(jù)庫連接池,Commons DbUtils登疗,批處理脱吱,元數(shù)據(jù)

數(shù)據(jù)庫連接池

連接池介紹

實際開發(fā)中“獲得連接”或“釋放資源”是非常消耗系統(tǒng)資源的兩個過程女仰,為了解決此類性能問題疾忍,通常情況我們采用連接池技術(shù),來共享連接 Connection一罩。這樣我們就不需要每次都創(chuàng)建連接撇簿、釋放連接了,因為這些操作都交給了連接池四瘫。

連接池的好處:使用池來管理 Connection汉嗽,這樣可以重復(fù)使用 Connection找蜜。當(dāng)使用完 Connection 后洗做,調(diào)用 Connection 的 close() 方法也不會真的關(guān)閉 Connection,而是把 Connection “歸還”給池畦徘。

如何使用數(shù)據(jù)庫連接池

Java 為數(shù)據(jù)庫連接池提供了公共的接口:javax.sql.DataSource影钉,各個廠商需要讓自己的連接池實現(xiàn)這個接口画髓,這樣應(yīng)用程序可以方便的切換不同廠商的連接池掘剪。

常見的連接池有 DBCP 連接池平委,C3P0 連接池,Druid 連接池夺谁。

數(shù)據(jù)準(zhǔn)備

在 MySQL 中準(zhǔn)備好以下數(shù)據(jù)

-- 創(chuàng)建數(shù)據(jù)庫
CREATE DATABASE db5 CHARACTER SET utf8;
 
-- 使用數(shù)據(jù)庫
USE db5;
 
-- 創(chuàng)建員工表
CREATE TABLE employee (
    eid INT PRIMARY KEY AUTO_INCREMENT,
    ename VARCHAR (20), -- 員工姓名
    age INT,            -- 員工年齡
    sex VARCHAR (6),    -- 員工性別
    salary DOUBLE,      -- 薪水
    empdate DATE        -- 入職日期
);
 
-- 插入數(shù)據(jù)
INSERT INTO employee (eid, ename, age, sex, salary, empdate) VALUES(NULL,'李清照',22,'女',4000,'2018-11-12');
INSERT INTO employee (eid, ename, age, sex, salary, empdate) VALUES(NULL,'林黛玉',20,'女',5000,'2019-03-14');
INSERT INTO employee (eid, ename, age, sex, salary, empdate) VALUES(NULL,'杜甫',40,'男',6000,'2020-01-01');
INSERT INTO employee (eid, ename, age, sex, salary, empdate) VALUES(NULL,'李白',25,'男',3000,'2017-10-01');
  • DBCP 連接池

DBCP 是一個開源的連接池廉赔,是 Apache 成員之一,在企業(yè)開發(fā)中比較常見匾鸥,Tomcat 內(nèi)置的連接池蜡塌。

1. 創(chuàng)建項目并導(dǎo)入 jar包
首先將 commons-dbcp 和 commons-pool 兩個 jar 包添加到 myJar 文件夾中,然后添加 myJar 庫到項目的依賴中勿负。

2.編寫工具類
連接數(shù)據(jù)庫表的工具類馏艾,采用 DBCP 連接池的方式來完成。

在 DBCP 包中提供了 DataSource 接口的實現(xiàn)類奴愉,我們要用的具體的連接池 BasicDataSource 類琅摩。

public class DBCPUtils {
    // 定義常量 保存數(shù)據(jù)庫連接的相關(guān)信息
    public static final String DRIVERNAME = "com.mysql.jdbc.Driver";
    public static final String URL = "jdbc:mysql://localhost:3306/db5?characterEncoding=UTF-8";
    public static final String USERNAME = "root";
    public static final String PASSWORD = "123456";

    // 創(chuàng)建連接池對象 (有 DBCP 提供的實現(xiàn)類)
    public static BasicDataSource dataSource = new BasicDataSource();

    // 使用靜態(tài)代碼塊進(jìn)行配置
    static{
        dataSource.setDriverClassName(DRIVERNAME);
        dataSource.setUrl(URL);
        dataSource.setUsername(USERNAME);
        dataSource.setPassword(PASSWORD);
    }

    // 獲取連接的方法
    public static Connection getConnection() throws SQLException {
        // 從連接池中獲取連接
        Connection connection = dataSource.getConnection();
        return connection;
    }

    // 釋放資源方法

    public static void close(Connection con, Statement statement){
        if(con != null && statement != null){
            try {
                statement.close();
                // 歸還連接
                con.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }

    }

    public static void close(Connection con, Statement statement, ResultSet resultSet){
        if(con != null && statement != null && resultSet != null){
            try {
                resultSet.close();
                statement.close();
                // 歸還連接
                con.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

3. 測試工具類

/*
 * 查詢所有員工的姓名
 **/
public class TestDBCP {
    public static void main(String[] args) throws SQLException {
        // 從 DBCP 連接池中拿到連接
        Connection con = DBCPUtils.getConnection();

        // 獲取 Statement 對象
        Statement statement = con.createStatement();

        // 查詢所有員工的姓名
        String sql = "select ename from employee";
        ResultSet resultSet = statement.executeQuery(sql);

        // 處理結(jié)果集
        while(resultSet.next()){
            String ename = resultSet.getString("ename");
            System.out.println("員工姓名: " + ename);
        }

        // 釋放資源
        DBCPUtils.close(con, statement, resultSet);
    }
}
  • C3P0 連接池

C3P0 是一個開源的 JDBC 連接池,支持 JDBC 3 規(guī)范和 JDBC 2 的標(biāo)準(zhǔn)擴(kuò)展锭硼。目前使用它的開源項目有 Hibernate房资、Spring 等。

1. 導(dǎo)入 jar 包及配置文件
首先將 c3p0 和 mchange-commons-java 兩個 jar 包復(fù)制到 myJar 文件夾即可檀头,IDEA 會自動導(dǎo)入轰异。

然后導(dǎo)入配置文件 c3p0-con?g.xml。c3p0-con?g.xml 文件名不可更改暑始,可以直接放到 src 下搭独,也可以放到到資源文件夾中宏胯。

最后在項目下創(chuàng)建一個 resource 文件夾(專門存放資源文件)甥厦,將配置文件放在 resource 目錄下即可档桃,創(chuàng)建連接池對象的時候會自動加載這個配置文件贡茅。

<c3p0-config>

    <!--默認(rèn)配置-->
    <default-config>
        <property name="driverClass">com.mysql.jdbc.Driver</property>
        <property name="jdbcUrl">jdbc:mysql://localhost:3306/db5?characterEncoding=UTF-8</property>
        <property name="user">root</property>
        <property name="password">123456</property>
        <!-- initialPoolSize:初始化時獲取三個連接吃靠,取值在 minPoolSize 與 maxPoolSize 之間镊尺。-->
        <property name="initialPoolSize">3</property>
        <!-- maxIdleTime:最大空閑時間烙样,60 秒內(nèi)未使用則連接被丟棄开仰。若為 0 則永不丟棄播赁。-->
        <property name="maxIdleTime">60</property>
        <!-- maxPoolSize:連接池中保留的最大連接數(shù) -->
        <property name="maxPoolSize">100</property>
        <!-- minPoolSize: 連接池中保留的最小連接數(shù) -->
        <property name="minPoolSize">10</property>
    </default-config>

    <!--配置連接池 mysql-->
    <named-config name="mysql">
        <property name="driverClass">com.mysql.jdbc.Driver</property>
        <property name="jdbcUrl">jdbc:mysql://localhost:3306/db5</property>
        <property name="user">root</property>
        <property name="password">root</property>
        <property name="initialPoolSize">10</property>
        <property name="maxIdleTime">30</property>
        <property name="maxPoolSize">100</property>
        <property name="minPoolSize">10</property>
    </named-config>

    <!--可以配置多個連接池-->

</c3p0-config>

2. 編寫 C3P0 工具類
C3P0 提供的核心工具類 ComboPooledDataSource颂郎,如果想使用連接池,就必須創(chuàng)建該類的對象容为。

使用默認(rèn)配置:new ComboPooledDataSource();

使用命名配置:new ComboPooledDataSource("mysql");

public class C3P0Utils {
    // 使用指定的配置
    public static ComboPooledDataSource dataSource = new ComboPooledDataSource("mysql");

    // 獲取連接的方法
    public static Connection getConnection() throws SQLException {
        return dataSource.getConnection();
    }

    // 釋放資源

    public static void close(Connection con, Statement statement){
        if(con != null && statement != null){
            try {
                statement.close();
                // 歸還連接
                con.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

    public static void close(Connection con, Statement statement, ResultSet resultSet){
        if(con != null && statement != null && resultSet != null){
            try {
                resultSet.close();
                statement.close();
                // 歸還連接
                con.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }

    }
}

3. 測試工具類

// 查詢姓名為李白的記錄
public class TestC3P0 {
    public static void main(String[] args) throws SQLException {
        // 獲取連接
        Connection con = C3P0Utils.getConnection();

        // 獲取預(yù)處理對象
        String sql = "select * from employee where ename = ?";
        PreparedStatement ps = con.prepareStatement(sql);

        // 設(shè)置占位符的值
        ps.setString(1,"李白");
        ResultSet resultSet = ps.executeQuery();

        // 處理結(jié)果集
        while (resultSet.next()){
            int eid = resultSet.getInt("eid");
            String ename = resultSet.getString("ename");
            int age = resultSet.getInt("age");
            String sex = resultSet.getString("sex");
            double salary = resultSet.getDouble("salary");
            Date date = resultSet.getDate("empdate");
            System.out.println(eid+" "+ename+" "+age+" "+sex+" "+salary+" "+date);
        }

        // 釋放資源
        C3P0Utils.close(con, ps, resultSet);
    }
}
  • Druid 連接池

Druid(德魯伊)是阿里巴巴開發(fā)的為監(jiān)控而生的數(shù)據(jù)庫連接池乓序,Druid 是目前最好的數(shù)據(jù)庫連接池寺酪。在功能、性能替劈、擴(kuò)展性方面寄雀,都超過其他數(shù)據(jù)庫連接池,同時加入了日志監(jiān)控陨献,可以很好的監(jiān)控 DB 池連接和 SQL 的執(zhí)行情況盒犹。

1. 導(dǎo)入 jar 包及配置文件
首先導(dǎo)入 druid jar 包。然后導(dǎo)入 properties 配置文件眨业,可以叫任意名稱急膀,可以放在任意目錄下,但是這里統(tǒng)一放到 resources 資源目錄龄捡。

driverClassName=com.mysql.jdbc.Driver
url=jdbc:mysql://127.0.0.1:3306/db5?characterEncoding=UTF-8
username=root
password=123456
initialSize=5
maxActive=10
maxWait=3000

2. 編寫 Druid 工具類
通過工廠來來獲取 DruidDataSourceFactory 類的 createDataSource(Properties p) 方法卓嫂,其參數(shù)可以是一個屬性集對象。

public class DruidUtils {

    // 定義成員變量
    public static DataSource dataSource;

    // 靜態(tài)代碼塊
    static{
        try {
            // 創(chuàng)建屬性集對象
            Properties p = new Properties();
            // 加載配置文件 Druid 連接池不能夠主動加載配置文件聘殖,需要指定文件
            InputStream inputStream = DruidUtils.class.getClassLoader().getResourceAsStream("druid.properties");
            // 使用 Properties 對象的 load 方法從字節(jié)流中讀取配置信息
            p.load(inputStream);
            // 通過工廠類獲取連接池對象
            dataSource = DruidDataSourceFactory.createDataSource(p);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    // 獲取連接的方法
    public static Connection getConnection(){
        try {
            return dataSource.getConnection();
        } catch (SQLException e) {
            e.printStackTrace();
            return null;
        }
    }

    // 釋放資源

    public static void close(Connection con, Statement statement){
        if(con != null && statement != null){
            try {
                statement.close();
                // 歸還連接
                con.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }

    }

    public static void close(Connection con, Statement statement, ResultSet resultSet){
        if(con != null && statement != null && resultSet != null){
            try {
                resultSet.close();
                statement.close();
                // 歸還連接
                con.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

3. 測試工具類

// 查詢薪資在 3000 - 5000 元之間的員工姓名
public class TestDruid {
    public static void main(String[] args) throws SQLException {
        // 獲取連接
        Connection con = DruidUtils.getConnection();

        // 獲取 Statement 對象
        Statement statement = con.createStatement();

        // 執(zhí)行查詢
        ResultSet resultSet = statement.executeQuery("select ename from employee where salary between 3000 and 5000");

        // 處理結(jié)果集
        while(resultSet.next()){
            String ename = resultSet.getString("ename");
            System.out.println(ename);
        }

        // 釋放資源
        DruidUtils.close(con,statement,resultSet);
    }
}

DBUtils工具類

DBUtils簡介

Commons DbUtils 是 Apache 組織提供的一個對 JDBC 進(jìn)行簡單封裝的開源工具類庫晨雳,使用它能夠簡化 JDBC 應(yīng)用程序的開發(fā),同時也不會影響程序的性能奸腺。

DbUtils 就是 JDBC 的簡化開發(fā)工具包餐禁,需要在項目導(dǎo)入 commons-dbutils jar 包。

DbUtils 核心功能:

  1. QueryRunner 中提供對 SQL 語句操作的 API洋机。
  2. ResultSetHandler 接口用于定義 select 操作后封裝結(jié)果集坠宴。
  3. DbUtils 類是一個定義了關(guān)閉資源與事務(wù)處理相關(guān)方法的工具類。

表和類之間的關(guān)系

整個表可以看做是一個類绷旗。
表中的一列喜鼓,對應(yīng)類中的一個成員屬性。
表中的一行記錄衔肢,對應(yīng)一個類的實例(對象)庄岖。

JavaBean 組件
JavaBean 是一個開發(fā)中通常用于封裝數(shù)據(jù)的類:

  1. 需要實現(xiàn)序列化接口,Serializable(暫時可以省略)
  2. 提供私有字段:private 類型變量名
  3. 提供 getter 和 setter
  4. 提供空參構(gòu)造

創(chuàng)建一個 entity 包角骤,專門用來存放 JavaBean 類隅忿,然后在 entity 包中創(chuàng)建一個和數(shù)據(jù)庫的 Employee 表對應(yīng)的 Employee 類。

public class Employee implements Serializable {
    private int eid;
    private String ename;
    private int age;
    private String  sex;
    private double salary;
    private Date empdate;
    // getter setter
    ...
}

DBUtils完成 CRUD

QueryRunner 的創(chuàng)建

手動模式

// 創(chuàng)建 QueryRunner 對象
QueryRunner qr = new QueryRunner();

自動模式

// 傳入數(shù)據(jù)庫連接池對象
QueryRunner qr2 = new QueryRunner(DruidUtils.getDataSource());

自動模式需要傳入連接池對象

// 獲取連接池對象
public static DataSource getDataSource(){
    return dataSource;
}
QueryRunner 實現(xiàn)增邦尊、刪背桐、改操作

步驟:

  1. 創(chuàng)建 QueryRunner(手動或自動)
  2. 占位符方式編寫SQL
  3. 設(shè)置占位符參數(shù)
  4. 執(zhí)行

添加:

@Test
public void testInsert() throws SQLException {
    // 手動模式創(chuàng)建 QueryRunner
    QueryRunner qr = new QueryRunner();

    // 編寫占位符方式 SQL
    String sql = "insert into employee values(?,?,?,?,?,?)";

    // 設(shè)置占位符的參數(shù)
    Object[] param = {null,"布萊爾",20,"女",10000,"1990-12-26"};

    // 執(zhí)行 update 方法
    Connection con = DruidUtils.getConnection();
    int i = qr.update(con, sql, param);

    // 釋放資源
    DbUtils.closeQuietly(con);
}

修改:

@Test
public void testUpdate() throws SQLException {
    // 自動模式創(chuàng)建 QueryRunner 對象,傳入數(shù)據(jù)庫連接池
    QueryRunner qr = new QueryRunner(DruidUtils.getDataSource());

    // 編寫 SQL
    String sql = "update employee set salary = ? where ename = ?";

    // 設(shè)置占位符參數(shù)
    Object[] param = {0, "布萊爾"};

    // 執(zhí)行 update蝉揍,不需要傳入連接對象
    qr.update(sql, param);
}

刪除:

@Test
public void testDelete() throws SQLException {
    QueryRunner qr = new QueryRunner(DruidUtils.getDataSource());

    String sql = "delete from employee where eid = ?";

    //只有一個參數(shù)链峭,不需要創(chuàng)建數(shù)組
    qr.update(sql, 1);
}


QueryRunner實現(xiàn)查詢操作

ResultSetHandler 可以對查詢出來的 ResultSet 結(jié)果集進(jìn)行處理,達(dá)到一些業(yè)務(wù)上的需求又沾。

query 方法的返回值都是泛型弊仪,具體的返回值類型會根據(jù)結(jié)果集的處理方式發(fā)生變化熙卡。

query(String sql, ResultSetHandler rsh, Object[] param) -- 自動模式創(chuàng)建QueryRunner, 執(zhí)行查詢。

query(Connection con, String sql, ResultSetHandler rsh, Object[] param) -- 手動模式創(chuàng)建 QueryRunner, 執(zhí)行查詢励饵。

/*
 * 查詢 id 為 5 的記錄驳癌,封裝到數(shù)組中
 *
 * ArrayHandler:
 * 將結(jié)果集的第一條數(shù)據(jù)封裝到 Object[] 數(shù)組中,
 * 數(shù)組中的每一個元素就是這條記錄中的每一個字段的值
 **/
@Test
public void testFindById() throws SQLException {
    // 創(chuàng)建 QueryRunner
    QueryRunner qr = new QueryRunner(DruidUtils.getDataSource());

    // 編寫 SQL
    String sql = "select * from employee where eid = ?";

    // 執(zhí)行查詢
    Object[] query = qr.query(sql, new ArrayHandler(), 5);

    // 獲取數(shù)據(jù)
    System.out.println(Arrays.toString(query));
}

/**
 * 查詢所有數(shù)據(jù)役听,封裝到 List 集合中
 *
 * ArrayListHandler:
 * 可以將每條數(shù)據(jù)先封裝到 Object[] 數(shù)組中,
 * 再將數(shù)組封裝到集合中
 */
@Test
public void testFindAll() throws SQLException {

    //1.創(chuàng)建QueryRunner
    QueryRunner qr = new QueryRunner(DruidUtils.getDataSource());

    //2.編寫SQL
    String sql = "select * from employee";

    //3.執(zhí)行查詢
    List<Object[]> query = qr.query(sql, new ArrayListHandler());

    //4.遍歷集合獲取數(shù)據(jù)
    for (Object[] objects : query) {
        System.out.println(Arrays.toString(objects));
    }
}

/**
 * 查詢 id 為 3 的記錄,封裝到指定 JavaBean 中
 *
 * BeanHandler:
 * 將結(jié)果集的第一條數(shù)據(jù)封裝到 JavaBean 中
 **/
@Test
public void testFindByIdJavaBean() throws SQLException {

    QueryRunner qr = new QueryRunner(DruidUtils.getDataSource());

    String sql = "select * from employee where eid = ?";

    Employee employee = qr.query(sql, new BeanHandler<Employee>(Employee.class), 3);

    System.out.println(employee);
}

/*
 * 查詢薪資大于 3000 的所員工信息颓鲜,
 * 封裝到 JavaBean 中再封裝到 List 集合中
 *
 * BeanListHandler:
 * 將結(jié)果集的每一條和數(shù)據(jù)封裝到 JavaBean 中,
 * 再將 JavaBean 放到 List 集合中
 * */
@Test
public void testFindBySalary() throws SQLException {
    QueryRunner qr = new QueryRunner(DruidUtils.getDataSource());

    String sql = "select * from employee where salary > ?";

    List<Employee> list = qr.query(sql, new BeanListHandler<Employee>(Employee.class), 3000);

    for (Employee employee : list) {
        System.out.println(employee);
    }
}

/*
 * 查詢姓名是布萊爾的員工信息禾嫉,
 * 將結(jié)果封裝到 Map 集合中
 *
 * MapHandler:
 * 將結(jié)果集的第一條記錄封裝到 Map 中灾杰,
 * key 對應(yīng)的是列名蚊丐,
 * value 對應(yīng)的是列的值
 **/
@Test
public void testFindByName() throws SQLException {
    QueryRunner qr = new QueryRunner(DruidUtils.getDataSource());

    String sql = "select * from employee where ename = ?";

    Map<String, Object> map = qr.query(sql, new MapHandler(), "布萊爾");

    Set<Map.Entry<String, Object>> entries = map.entrySet();
    for (Map.Entry<String, Object> entry : entries) {
        System.out.println(entry.getKey() +" = " +entry.getValue());
    }
}

/*
 * 查詢所有員工的薪資總額
 *
 * ScalarHandler:
 * 用于封裝單個的數(shù)據(jù)
 **/
@Test
public void testGetSum() throws SQLException {
    QueryRunner qr = new QueryRunner(DruidUtils.getDataSource());

    String sql = "select sum(salary) from employee";

    Double sum = (Double) qr.query(sql, new ScalarHandler<>());

    System.out.println("員工薪資總額: " + sum);
}

數(shù)據(jù)庫批處理

什么是批處理

批處理操作數(shù)據(jù)庫:批處理指的是一次操作中執(zhí)行多條 SQL 語句熙参,批處理相比于一次一次執(zhí)行效率會提高很多。當(dāng)向數(shù)據(jù)庫中添加大量的數(shù)據(jù)時麦备,需要用到批處理孽椰。

實現(xiàn)批處理

Statement 和 PreparedStatement 都支持批處理操作。

MySQL 批處理是默認(rèn)關(guān)閉的凛篙,所以需要加一個參數(shù)才打開 MySQL 數(shù)據(jù)庫批處理黍匾,在 url 中添加 rewriteBatchedStatements=true。

url=jdbc:mysql://127.0.0.1:3306/db5?characterEncoding=UTF-8&rewriteBatchedStatements=true
  1. 創(chuàng)建一張表
CREATE TABLE testBatch (
    id INT PRIMARY KEY AUTO_INCREMENT,
    uname VARCHAR(50)
)
  1. 測試向表中插入一萬條數(shù)據(jù)
public class TestBatch {
    public static void main(String[] args) {
        try {
            // 獲取連接
            Connection con = DruidUtils.getConnection();

            // 獲取預(yù)處理對象
            String sql ="insert into testBatch(uname) values(?)";
            PreparedStatement ps = con.prepareStatement(sql);

            // 創(chuàng)建 for 循環(huán)來設(shè)置占位符參數(shù)
            for (int i = 0; i < 10000 ; i++) {
                ps.setString(1, "小明"+i);
                // 將 SQL 添加到批處理列表
                ps.addBatch();
            }

            long start = System.currentTimeMillis();

            // 統(tǒng)一批量執(zhí)行
            ps.executeBatch();
            
            long end = System.currentTimeMillis();
            System.out.println("插入10000條數(shù)據(jù)使用: "+(end-start)+" 毫秒!");
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

MySql元數(shù)據(jù)

什么是元數(shù)據(jù)

除了表之外的數(shù)據(jù)都是元數(shù)據(jù)呛梆,可以分為三類:

  1. 查詢結(jié)果信息锐涯,UPDATE 或 DELETE語句 受影響的記錄數(shù)。
  2. 數(shù)據(jù)庫和數(shù)據(jù)表的信息填物,包含了數(shù)據(jù)庫及數(shù)據(jù)表的結(jié)構(gòu)信息纹腌。
  3. MySQL服務(wù)器信,包含了數(shù)據(jù)庫服務(wù)器的當(dāng)前狀態(tài)滞磺,版本號等升薯。

常用命令

select version(); 獲取 MySQL 服務(wù)器的版本信息

show status; 查看服務(wù)器的狀態(tài)信息

show columns from table_name; 顯示表的字段信息等,和 desc table_name 一樣

show index from table_name; 顯示數(shù)據(jù)表的詳細(xì)索引信息击困,包括主鍵

show databases: 列出所有數(shù)據(jù)庫

show tables; 顯示當(dāng)前數(shù)據(jù)庫的所有表

select database(); 獲取當(dāng)前的數(shù)據(jù)庫名

使用 JDBC 獲取元數(shù)據(jù)

通過 JDBC 也可以獲取到元數(shù)據(jù)涎劈,比如,數(shù)據(jù)庫的相關(guān)信息阅茶,或者蛛枚,使用程序查詢一個不熟悉的表時,可以通過獲取元素?fù)?jù)信息來了解表中有多少個字段脸哀、字段的名稱蹦浦、字段的類型。

DatabaseMetaData 描述數(shù)據(jù)庫的元數(shù)據(jù)對象

ResultSetMetaData 描述結(jié)果集的元數(shù)據(jù)對象

public class TestMetaData {

    // 獲取數(shù)據(jù)庫相關(guān)的元數(shù)據(jù)信息
    @Test
    public void testDataBaseMetaData() throws SQLException {
        Connection connection = DruidUtils.getConnection();

        // 獲取代表數(shù)據(jù)庫的元數(shù)據(jù)對象
        DatabaseMetaData metaData = connection.getMetaData();

        // 獲取數(shù)據(jù)庫相關(guān)的元數(shù)據(jù)信息
        String url = metaData.getURL();
        System.out.println("數(shù)據(jù)庫URL: " + url);
        String userName = metaData.getUserName();
        System.out.println("當(dāng)前用戶: " + userName );
        String productName = metaData.getDatabaseProductName();
        System.out.println("數(shù)據(jù)庫產(chǎn)品名: " + productName);
        String version = metaData.getDatabaseProductVersion();
        System.out.println("數(shù)據(jù)庫版本: " + version);
        String driverName = metaData.getDriverName();
        System.out.println("驅(qū)動名稱: " + driverName);

        // 判斷當(dāng)前數(shù)據(jù)庫是否只允許只讀
        boolean b = metaData.isReadOnly();
        if(b){
            System.out.println("當(dāng)前數(shù)據(jù)庫只允許讀操作!");
        }else{
            System.out.println("不是只讀數(shù)據(jù)庫");
        }

        connection.close();
    }

    // 獲取結(jié)果集中的元數(shù)據(jù)信息
    @Test
    public void testResultSetMetaData() throws SQLException {
        Connection con = DruidUtils.getConnection();
        PreparedStatement ps = con.prepareStatement("select * from employee");
        ResultSet resultSet = ps.executeQuery();

        // 獲取結(jié)果集元素?fù)?jù)對象
        ResultSetMetaData metaData = ps.getMetaData();

        // 獲取當(dāng)前結(jié)果集共有多少列
        int count = metaData.getColumnCount();
        System.out.println("當(dāng)前結(jié)果集中共有: "+count+"列");

        // 獲結(jié)果集中列的名稱和類型
        for (int i = 1; i <=  count; i++) {
            String columnName = metaData.getColumnName(i);
            System.out.println("列名: "+columnName);

            String columnTypeName = metaData.getColumnTypeName(i);
            System.out.println("類型: "+columnTypeName);
        }

        DruidUtils.close(con, ps, resultSet);
    }
}
最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末企蹭,一起剝皮案震驚了整個濱河市白筹,隨后出現(xiàn)的幾起案子智末,更是在濱河造成了極大的恐慌,老刑警劉巖徒河,帶你破解...
    沈念sama閱讀 222,681評論 6 517
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件系馆,死亡現(xiàn)場離奇詭異,居然都是意外死亡顽照,警方通過查閱死者的電腦和手機(jī)由蘑,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 95,205評論 3 399
  • 文/潘曉璐 我一進(jìn)店門,熙熙樓的掌柜王于貴愁眉苦臉地迎上來代兵,“玉大人尼酿,你說我怎么就攤上這事≈灿埃” “怎么了裳擎?”我有些...
    開封第一講書人閱讀 169,421評論 0 362
  • 文/不壞的土叔 我叫張陵,是天一觀的道長思币。 經(jīng)常有香客問我鹿响,道長,這世上最難降的妖魔是什么谷饿? 我笑而不...
    開封第一講書人閱讀 60,114評論 1 300
  • 正文 為了忘掉前任惶我,我火速辦了婚禮,結(jié)果婚禮上博投,老公的妹妹穿的比我還像新娘绸贡。我一直安慰自己,他們只是感情好毅哗,可當(dāng)我...
    茶點故事閱讀 69,116評論 6 398
  • 文/花漫 我一把揭開白布听怕。 她就那樣靜靜地躺著,像睡著了一般黎做。 火紅的嫁衣襯著肌膚如雪叉跛。 梳的紋絲不亂的頭發(fā)上,一...
    開封第一講書人閱讀 52,713評論 1 312
  • 那天蒸殿,我揣著相機(jī)與錄音筷厘,去河邊找鬼。 笑死宏所,一個胖子當(dāng)著我的面吹牛酥艳,可吹牛的內(nèi)容都是我干的。 我是一名探鬼主播爬骤,決...
    沈念sama閱讀 41,170評論 3 422
  • 文/蒼蘭香墨 我猛地睜開眼充石,長吁一口氣:“原來是場噩夢啊……” “哼!你這毒婦竟也來了霞玄?” 一聲冷哼從身側(cè)響起骤铃,我...
    開封第一講書人閱讀 40,116評論 0 277
  • 序言:老撾萬榮一對情侶失蹤拉岁,失蹤者是張志新(化名)和其女友劉穎,沒想到半個月后惰爬,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體喊暖,經(jīng)...
    沈念sama閱讀 46,651評論 1 320
  • 正文 獨居荒郊野嶺守林人離奇死亡,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點故事閱讀 38,714評論 3 342
  • 正文 我和宋清朗相戀三年撕瞧,在試婚紗的時候發(fā)現(xiàn)自己被綠了陵叽。 大學(xué)時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
    茶點故事閱讀 40,865評論 1 353
  • 序言:一個原本活蹦亂跳的男人離奇死亡丛版,死狀恐怖巩掺,靈堂內(nèi)的尸體忽然破棺而出,到底是詐尸還是另有隱情页畦,我是刑警寧澤胖替,帶...
    沈念sama閱讀 36,527評論 5 351
  • 正文 年R本政府宣布,位于F島的核電站寇漫,受9級特大地震影響刊殉,放射性物質(zhì)發(fā)生泄漏。R本人自食惡果不足惜州胳,卻給世界環(huán)境...
    茶點故事閱讀 42,211評論 3 336
  • 文/蒙蒙 一、第九天 我趴在偏房一處隱蔽的房頂上張望逸月。 院中可真熱鬧栓撞,春花似錦、人聲如沸碗硬。這莊子的主人今日做“春日...
    開封第一講書人閱讀 32,699評論 0 25
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽恩尾。三九已至弛说,卻和暖如春,著一層夾襖步出監(jiān)牢的瞬間翰意,已是汗流浹背木人。 一陣腳步聲響...
    開封第一講書人閱讀 33,814評論 1 274
  • 我被黑心中介騙來泰國打工, 沒想到剛下飛機(jī)就差點兒被人妖公主榨干…… 1. 我叫王不留冀偶,地道東北人醒第。 一個月前我還...
    沈念sama閱讀 49,299評論 3 379
  • 正文 我出身青樓,卻偏偏與公主長得像进鸠,于是被迫代替她去往敵國和親稠曼。 傳聞我的和親對象是個殘疾皇子,可洞房花燭夜當(dāng)晚...
    茶點故事閱讀 45,870評論 2 361

推薦閱讀更多精彩內(nèi)容