成长（一）
package com.cxz.util;import java.sql.Connection;import java.sql.DriverManager;import java.sql.PreparedStatement;import java.sql.ResultSet;import java.sql.SQLException;import java.sql.Statement;import java.sql.Types;import java.sql.Date;import java.util.HashMap;import java.util.ArrayList;import java.util.ResourceBundle;public class DBConnector {private String jdbc = "";private String url = "";private String userName = "";private String password = "";private ResourceBundle bundle=null;public DBConnector() {//Properties prop = new Properties(); //prop.load(new FileInputStream("app.properties")); bundle=ResourceBundle.getBundle("info.entryexit_v15-info");jdbc=bundle.getString("jdbc");url=bundle.getString("url");userName=bundle.getString("userName");password=bundle.getString("password");//jdbc = prop.getProperty("jdbc");/*url = prop.getProperty("url");userName = prop.getProperty("userName");password = prop.getProperty("password");*/}public DBConnector(String jdbc, String url, String userName, String password) {this.jdbc = jdbc;this.url = url;this.userName = userName;this.password = password;}public Connection getConnection() throws SQLException,ClassNotFoundException {Class.forName(jdbc);return DriverManager.getConnection(url, userName, password);}private int questionCount(String sql) {int questions = 0;for (int i = 0; i < sql.length(); i++) {if (sql.charAt(i) == '?')questions++;}return questions;}public ArrayList<HashMap<String, Object>> doSelect(String sql,ArrayList params) throws Exception {Connection conn = null;PreparedStatement pstmt = null;ResultSet rs = null;ArrayList<HashMap<String, Object>> returns = new ArrayList<HashMap<String, Object>>();try {conn = getConnection();pstmt = conn.prepareStatement(sql);if (params != null) {// if the params is null it means no ?for (int i = 0; i < params.size(); i++) {if (params.get(i).getClass() == Integer.class) {pstmt.setInt(i + 1, (Integer) params.get(i));} else if (params.get(i).getClass() == String.class) {pstmt.setString(i + 1, (String) params.get(i));} else if (params.get(i).getClass() == Date.class) {pstmt.setDate(i + 1, (Date) params.get(i));} else {// for some other types}}if (questionCount(sql) != params.size()) {throw new Exception();}}rs = pstmt.executeQuery();while (rs.next()) {HashMap<String, Object> temp = new HashMap<String, Object>();for (int i = 1; i <= rs.getMetaData().getColumnCount(); i++) {if (rs.getMetaData().getColumnType(i) == Types.VARCHAR) {temp.put(rs.getMetaData().getColumnName(i), rs.getString(i));} else if (rs.getMetaData().getColumnType(i) == Types.INTEGER) {temp.put(rs.getMetaData().getColumnName(i), rs.getInt(i));} else if (rs.getMetaData().getColumnType(i) == Types.DATE) {temp.put(rs.getMetaData().getColumnName(i), rs.getDate(i));} else if (rs.getMetaData().getColumnType(i) == Types.DOUBLE) {temp.put(rs.getMetaData().getColumnName(i), rs.getDouble(i));} else {// some type else;}}returns.add(temp);}rs.close();pstmt.close();conn.close();} catch (Exception ex) {ex.printStackTrace();} finally {try {if (rs != null) {rs.close();}} catch (SQLException e) {e.printStackTrace();}try {if (pstmt != null) {pstmt.close();}} catch (SQLException e) {e.printStackTrace();}try {if (conn != null) {conn.close();}} catch (SQLException e) {e.printStackTrace();}}return returns;}public void closeConn(Connection conn) {try {if (conn != null) {conn.close();}} catch (SQLException e) {// TODO Auto-generated catch blocke.printStackTrace();}}public void closeStmt(Statement stmt) {try {if (stmt != null) {stmt.close();}} catch (SQLException e) {// TODO Auto-generated catch blocke.printStackTrace();}}public void closePstmt(PreparedStatement pstmt) {try {if (pstmt != null) {pstmt.close();}} catch (SQLException e) {// TODO Auto-generated catch blocke.printStackTrace();}}public void closeRs(ResultSet rs) {try {if (rs != null) {rs.close();}} catch (SQLException e) {// TODO Auto-generated catch blocke.printStackTrace();}}public static void main(String args[]) {DBConnector test=new DBConnector();}
页:
[1]