java jdbc操作數據庫通用代碼

1.准備工作

1》

新建一個配置文件，名為jdbc.properties將其放入src中

2》在項目中導入jdbc驅動，注意連接不同的數據庫，所用到的驅動是不一樣的，這些在網上都能找到

具體導入jar的方法，請參照http://blog.csdn.net/mazhaojuan/article/details/21403717

2、代碼

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

public class Main {
    public static void main(String[] args) {
        DBUtil dbUtil = new DBUtil();
        dbUtil.R("select * from table");
    }
}

class DBUtil{
    /**
     * 得到數據庫連接
     * @return
     * @throws Exception
     */
    public Connection getConnection() throws Exception{
        //1.創建配置文件並得到對象輸入流
        InputStream is = this.getClass().getClassLoader().getResourceAsStream("jdbc.properties");
        //2.創建propetities
        Properties jdbc = new Properties();
        jdbc.load(is);
        //3. 通過key-value 的方式得到對應的值
        String driver = jdbc.getProperty("driver");
        String url = jdbc.getProperty("url");
        String user = jdbc.getProperty("user");
        String password = jdbc.getProperty("password");
        //4.加載運行時類對象
        Class.forName(driver);
        //5通過DriverManager得到連接
        Connection connection = DriverManager.getConnection(url,user,password);
        return connection;
        
    }
    /**
     * 釋放資源的方法
     * @param connection
     * @param statement      
     * @param resultSet
     */
    public void release(Connection connection,Statement statement,ResultSet resultSet){
        try {
            if(resultSet!=null){
                resultSet.close();
            }
         } catch (SQLException e) {
            e.printStackTrace();
        }
         try {
            if(statement!=null){
                statement.close();
            }
          } catch (SQLException e) {
            e.printStackTrace();
          }
         try {
            if(connection!=null){
                connection.close();
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
        
    }
    /**
     * 查詢數據庫的方法
     * @param sql        字符串，要執行的sql語句  如果其中有變量的話，就用  ‘"+變量+"’
     */
    public void R(String sql){
        Connection connection = null;
        Statement statement = null;
        ResultSet resultSet = null;
        try {
            connection = getConnection();
            statement = connection.createStatement();
            resultSet = statement.executeQuery(sql);
            while(resultSet.next()!=false){
                //這里可以執行一些其他的操作
                System.out.println(resultSet.getString(1));
            }
        } catch (Exception e) {
            e.printStackTrace();
        }finally {
            release(connection, statement, resultSet);
        }
    }
    /**
     * 數據庫記錄增刪改的方法
     * @param sql        字符串，要執行的sql語句  如果其中有變量的話，就用  ‘"+變量+"’
     */
    public void CUD(String sql){
        Connection connection = null;
        Statement statement = null;
        int result = 0;
        try {
            connection = getConnection();
            statement = connection.createStatement();
            result = statement.executeUpdate(sql);
            
            //這里可以根據返回結果(影響記錄的條數) 進行判斷，該語句是否執行成功
            System.out.println(result);
        } catch (Exception e) {
            e.printStackTrace();
        }finally {
            release(connection, statement, null);
        }
    }
    
}        

3.預處理，其中上面的連接數據庫及釋放資源的方法不動

代碼如下：

import java.io.InputStream;
import java.sql.Connection;
import java.sql.DatabaseMetaData;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;

public class Main {
    public static void main(String[] args) {
       
    }
}

class DBUtil{
    /**
     * 得到數據庫連接
     * @return
     * @throws Exception
     */
    public Connection getConnection() throws Exception{
        //1.創建配置文件並得到對象輸入流
        InputStream is = this.getClass().getClassLoader().getResourceAsStream("jdbc.properties.txt");
        //2.創建propetities
        Properties jdbc = new Properties();
        jdbc.load(is);
        //3. 通過key-value 的方式得到對應的值
        String driver = jdbc.getProperty("driver");
        String url = jdbc.getProperty("url");
        String user = jdbc.getProperty("user");
        String password = jdbc.getProperty("password");
        //4.加載運行時類對象
        Class.forName(driver);
        //5通過DriverManager得到連接
        Connection connection = DriverManager.getConnection(url,user,password);
        return connection;
        
    }
    /**
     * 釋放資源的方法
     * @param connection
     * @param statement      
     * @param resultSet
     */
    public void release(Connection connection,Statement statement,ResultSet resultSet){
        try {
            if(resultSet!=null){
                resultSet.close();
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
        try {
             if(statement!=null){
                 statement.close();
             }
        } catch (Exception e) {
            // TODO: handle exception
        }
       try{
            if(connection!=null){
                connection.close();
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
        
    }
    /**
     * 查詢數據庫的方法
     * @param sql        字符串，要執行的sql語句  如果其中有變量的話，就用  ‘"+變量+"’
     */
    public void R(String sql, Object ...args){
        Connection connection = null;
        PreparedStatement preparedStatement = null;
        ResultSet resultSet = null;
        try {
            connection = getConnection();
            preparedStatement = connection.prepareStatement(sql);
            for (int i = 0; i < args.length; i++) {
                preparedStatement.setObject(i+1, args[i]);
            }
            resultSet = preparedStatement.executeQuery();
            ResultSetMetaData resultSetMetaData = resultSet.getMetaData();
            int columnCount = resultSetMetaData.getColumnCount();
            while(resultSet.next()!=false){
                //這里可以執行一些其他的操作
                for (int i = 1; i <= columnCount; i++) {
                    System.out.println(resultSet.getString(i));
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
        }finally {
            release(connection, preparedStatement, resultSet);
        }
    }
    /**
     * 數據庫記錄增刪改的方法
     * @param sql        字符串，要執行的sql語句  如果其中有變量的話，就用  ‘"+變量+"’
     */
    public void CUD(String sql, Object ...args){
        Connection connection = null;
        PreparedStatement preparedStatement = null;
        int result = 0;
        try {
            connection = getConnection();
            preparedStatement = connection.prepareStatement(sql);
            for (int i = 0; i < args.length; i++) {
                preparedStatement.setObject(i+1, args[i]);
            }
            result = preparedStatement.executeUpdate();
            //這里可以根據返回結果(影響記錄的條數)進行判斷，該語句是否執行成功
            System.out.println(result);
        } catch (Exception e) {
            e.printStackTrace();
        }finally {
            release(connection, preparedStatement, null);
        }
    }  
    
}

在預處理代碼第87行使用了元數據獲取集合中的列的數量  有關數據庫 元數據，請參考文檔上的相關接口：

DatabaseMetaData

ResultSetMetaData

 注：本文為原創，如需轉載請注明出處：http://www.cnblogs.com/zhuchenglin/p/7919803.html