JDBC深度封裝的工具類

jopen 10年前發布 | 3K 次閱讀 Java JDBC
首先介紹一下Dbutils：
Common Dbutils是操作數據庫的組件，對傳統操作數據庫的類進行二次封裝，可以把結果集轉化成List。補充一下，傳統操作數據庫的類指的是JDBC（java database connection：java數據庫連接，java的數據庫操作的基礎API。）。 DBUtils是java編程中的數據庫操作實用工具，小巧簡單實用。有興趣的話可以到官網下載：http://commons.apache.org/dbutils/ 下面的工具包正是符合了Common Dbutils 的思想
package com.util;

import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.lang.reflect.Field;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Properties;

public class JdbcUtils
{

    // 表示定義數據庫的用戶名
    private final String USERNAME = "root";
    // 定義數據庫的密碼
    private final String PASSWORD = "admin";
    // 定義數據庫的驅動信息
    private final String DRIVER = "com.mysql.jdbc.Driver";
    // 定義訪問數據庫的地址
    private final String URL = "jdbc:mysql://localhost:3306/mydb";
    // 定義數據庫的鏈接
    private Connection connection;
    // 定義sql語句的執行對象
    private PreparedStatement pstmt;
    // 定義查詢返回的結果集合
    private ResultSet resultSet;

    public JdbcUtils()
    {
        try
        {
            Class.forName(DRIVER);
            System.out.println("注冊驅動成功!!");
        }
        catch (Exception e)
        {
            // TODO: handle exception
        }
    }

    // 定義獲得數據庫的鏈接
    public Connection getConnection()
    {
        try
        {
            connection = DriverManager.getConnection(URL, USERNAME, PASSWORD);
            System.out.println("數據庫連接成功");
        }
        catch (Exception e)
        {
            // TODO: handle exception
        }
        return connection;
    }


    public boolean updateByPreparedStatement(String sql, Listparams)
            throws SQLException
    {
        boolean flag = false;
        int result = -1;// 表示當用戶執行添加刪除和修改的時候所影響數據庫的行數
        pstmt = connection.prepareStatement(sql);
        int index = 1;
        // 填充sql語句中的占位符
        if (params != null && !params.isEmpty())
        {
            for (int i = 0; i < params.size(); i++)
            {
                pstmt.setObject(index++, params.get(i));
            }
        }
        result = pstmt.executeUpdate();
        flag = result > 0 ? true : false;
        return flag;
    }


    public Map findSimpleResult(String sql, Listparams)
            throws SQLException
    {
        Map map = new HashMap();
        int index = 1;
        pstmt = connection.prepareStatement(sql);
        if (params != null && !params.isEmpty())
        {
            for (int i = 0; i < params.size(); i++)
            {
                pstmt.setObject(index++, params.get(i));
            }
        }
        resultSet = pstmt.executeQuery();// 返回查詢結果
        // 獲取此 ResultSet 對象的列的編號、類型和屬性。
        ResultSetMetaData metaData = resultSet.getMetaData();
        int col_len = metaData.getColumnCount();// 獲取列的長度
        while (resultSet.next())// 獲得列的名稱
        {
            for (int i = 0; i < col_len; i++)
            {
                String cols_name = metaData.getColumnName(i + 1);
                Object cols_value = resultSet.getObject(cols_name);
                if (cols_value == null)// 列的值沒有時，設置列值為“”
                {
                    cols_value = "";
                }
                map.put(cols_name, cols_value);
            }
        }
        return map;
    }


    public List> findMoreResult(String sql,
            Listparams) throws SQLException
    {
        List> list = new ArrayList>();
        int index = 1;
        pstmt = connection.prepareStatement(sql);
        if (params != null && !params.isEmpty())
        {
            for (int i = 0; i < params.size(); i++)
            {
                pstmt.setObject(index++, params.get(i));
            }
        }
        resultSet = pstmt.executeQuery();
        ResultSetMetaData metaData = resultSet.getMetaData();
        int cols_len = metaData.getColumnCount();
        while (resultSet.next())
        {
            Map map = new HashMap();
            for (int i = 0; i < cols_len; i++)
            {
                String cols_name = metaData.getColumnName(i + 1);
                Object cols_value = resultSet.getObject(cols_name);
                if (cols_value == null)
                {
                    cols_value = "";
                }
                map.put(cols_name, cols_value);
            }
            list.add(map);
        }
        return list;
    }


    public T findSimpleRefResult(String sql, Listparams,
            Class cls) throws Exception
    {
        T resultObject = null;
        int index = 1;
        pstmt = connection.prepareStatement(sql);
        if (params != null && !params.isEmpty())
        {
            for (int i = 0; i < params.size(); i++)
            {
                pstmt.setObject(index++, params.get(i));
            }
        }
        resultSet = pstmt.executeQuery();
        ResultSetMetaData metaData = resultSet.getMetaData();
        int cols_len = metaData.getColumnCount();
        while (resultSet.next())
        {
            // 通過反射機制創建實例
            resultObject = cls.newInstance();
            for (int i = 0; i < cols_len; i++)
            {
                String cols_name = metaData.getColumnName(i + 1);
                Object cols_value = resultSet.getObject(cols_name);
                if (cols_value == null)
                {
                    cols_value = "";
                }
                // 返回一個 Field 對象，該對象反映此 Class 對象所表示的類或接口的指定已聲明字段。
               Field field = cls.getDeclaredField(cols_name);
                field.setAccessible(true);// 打開javabean的訪問private權限
                field.set(resultObject, cols_value);// 為resultObject對象的field的屬性賦值
            } //上面的兩行紅題字就是要求實體類中的屬性名一定要和數據庫中的字段名一定要嚴//格相同（包括大小寫）,而oracle數據庫中一般都是大寫的，如何讓oracle區分大小寫，請看博///文：http://blog.sina.com.cn/s/blog_7ffb8dd501013xkq.html
        }
        return resultObject;
    }


    public List findMoreRefResult(String sql, Listparams,
            Class cls) throws Exception
    {
        List list = new ArrayList();
        int index = 1;
        pstmt = connection.prepareStatement(sql);
        if (params != null && !params.isEmpty())
        {
            for (int i = 0; i < params.size(); i++)
            {
                pstmt.setObject(index++, params.get(i));
            }
        }
        resultSet = pstmt.executeQuery();
        ResultSetMetaData metaData = resultSet.getMetaData();
        int cols_len = metaData.getColumnCount();
        while (resultSet.next())
        {
            T resultObject = cls.newInstance();
            for (int i = 0; i < cols_len; i++)
            {
                String cols_name = metaData.getColumnName(i + 1);
                Object cols_value = resultSet.getObject(cols_name);
                if (cols_value == null)
                {
                    cols_value = "";
                }
                Field field = cls.getDeclaredField(cols_name);
                field.setAccessible(true);
                field.set(resultObject, cols_value);
            }
            list.add(resultObject);
        }
        return list;
    }


    public void releaseConn()
    {
        if (resultSet != null)
        {
            try
            {
                resultSet.close();
            }
            catch (SQLException e)
            {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
        if (pstmt != null)
        {
            try
            {
                pstmt.close();
            }
            catch (SQLException e)
            {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
        if (connection != null)
        {
            try
            {
                connection.close();
            }
            catch (SQLException e)
            {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
    }


    public static void writeProperties(String url, String user, String password)
    {
        Properties pro = new Properties();
        FileOutputStream fileOut = null;
        try
        {
            fileOut = new FileOutputStream("Config.ini");
            pro.put("url", url);
            pro.put("user", user);
            pro.put("password", password);
            pro.store(fileOut, "My Config");
        }
        catch (Exception e)
        {
            e.printStackTrace();
        }
        finally
        {

            try
            {
                if (fileOut != null)
                    fileOut.close();
            }
            catch (IOException e)
            {
                e.printStackTrace();
            }
        }
    }


    public static List readProperties()
    {
        List list = new ArrayList();
        Properties pro = new Properties();
        FileInputStream fileIn = null;
        try
        {
            fileIn = new FileInputStream("Config.ini");
            pro.load(fileIn);
            list.add(pro.getProperty("url"));
            list.add(pro.getProperty("user"));
            list.add(pro.getProperty("password"));
        }
        catch (Exception e)
        {
            e.printStackTrace();
        }
        finally
        {

            try
            {
                if (fileIn != null)
                    fileIn.close();
            }
            catch (IOException e)
            {
                e.printStackTrace();
            }
        }
        return list;
    }


    public static void main(String[] args)
    {
        // TODO Auto-generated method stub
        JdbcUtils jdbcUtils = new JdbcUtils();
        jdbcUtils.getConnection();
        // String sql = "insert into userinfo(username,pswd) values(?,?)";
        // Listparams = new ArrayList();
        // params.add("rose");
        // params.add("123");
        // try {
        // boolean flag = jdbcUtils.updateByPreparedStatement(sql, params);
        // System.out.println(flag);
        // } catch (SQLException e) {
        // // TODO Auto-generated catch block
        // e.printStackTrace();
        // }
        String sql = "select * from userinfo ";
        // Listparams = new ArrayList();
        // params.add(1);

    }

}
本文由用戶 jopen 自行上傳分享，僅供網友學習交流。所有權歸原作者，若您的權利被侵害，請聯系管理員。
轉載本站原創文章，請注明出處，并保留原始鏈接、圖片水印。
本站是一個以用戶分享為主的開源技術平臺，歡迎各類分享！
本文地址：http://www.baiduhome.net/code/view/1433492370619
Java JDBC
JDBC深度封裝的工具類

相關代碼

相關文檔

相關經驗

目錄
