package com.tools; import java.sql.*; import java.io.*; import java.util.*; public class ConnDB { public Connection conn = null; public Statement stmt = null; public ResultSet rs = null; private static String propFileName = "/com/connDB.properties"; // Ö¸¶¨×ÊÔ´Îļþ±£´æµÄλÖà private static Properties prop = new Properties(); private static String dbClassName = "com.microsoft.sqlserver.jdbc.SQLServerDriver"; private static String dbUrl = "jdbc:sqlserver://localhost:1433;DatabaseName=db_shop"; private static String dbUser = "sa"; private static String dbPwd = ""; public ConnDB() { try { InputStream in = getClass().getResourceAsStream(propFileName); prop.load(in); // ͨ¹ýÊäÈëÁ÷¶ÔÏó¼ÓÔØPropertiesÎļþ dbClassName = prop.getProperty("DB_CLASS_NAME"); // »ñÈ¡Êý¾Ý¿âÇý¶¯ dbUrl = prop.getProperty("DB_URL", dbUrl); dbUser = prop.getProperty("DB_USER", dbUser); dbPwd = prop.getProperty("DB_PWD", dbPwd); } catch (Exception e) { e.printStackTrace(); // Êä³öÒì³£ÐÅÏ¢ } } public static Connection getConnection() { Connection conn = null; try { Class.forName(dbClassName).newInstance(); conn = DriverManager.getConnection(dbUrl, dbUser, dbPwd); } catch (Exception ee) { ee.printStackTrace(); } if (conn == null) { System.err .println("¾¯¸æ: DbConnectionManager.getConnection() »ñµÃÊý¾Ý¿âÁ´½Óʧ°Ü.\r\n\r\nÁ´½ÓÀàÐÍ:" + dbClassName + "\r\nÁ´½ÓλÖÃ:" + dbUrl + "\r\nÓû§/ÃÜÂë" + dbUser + "/" + dbPwd); } return conn; } /* * ¹¦ÄÜ£ºÖ´ÐвéѯÓï¾ä */ public ResultSet executeQuery(String sql) { try { // ²¶×½Òì³£ conn = getConnection(); // µ÷ÓÃgetConnection()·½·¨¹¹ÔìConnection¶ÔÏóµÄÒ»¸öʵÀýconn stmt = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY); rs = stmt.executeQuery(sql); } catch (SQLException ex) { System.err.println(ex.getMessage()); // Êä³öÒì³£ÐÅÏ¢ } return rs; // ·µ»Ø½á¹û¼¯¶ÔÏó } /* * ¹¦ÄÜ:Ö´ÐиüвÙ×÷ */ public int executeUpdate(String sql) { int result = 0; // ¶¨Òå±£´æ·µ»ØÖµµÄ±äÁ¿ try { // ²¶×½Òì³£ conn = getConnection(); // µ÷ÓÃgetConnection()·½·¨¹¹ÔìConnection¶ÔÏóµÄÒ»¸öʵÀýconn stmt = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY); result = stmt.executeUpdate(sql); // Ö´ÐиüвÙ×÷ } catch (SQLException ex) { result = 0; // ½«±£´æ·µ»ØÖµµÄ±äÁ¿¸³ÖµÎª0 } try { stmt.close(); } catch (SQLException ex1) { } return result; // ·µ»Ø±£´æ·µ»ØÖµµÄ±äÁ¿ } public int executeUpdate_id(String sql) { int result = 0; // ¶¨Òå±£´æ·µ»ØÖµµÄ±äÁ¿ try { // ²¶×½Òì³£ conn = getConnection(); // µ÷ÓÃgetConnection()·½·¨¹¹ÔìConnection¶ÔÏóµÄÒ»¸öʵÀýconn stmt = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY); result = stmt.executeUpdate(sql); // Ö´ÐиüвÙ×÷ // »ñÈ¡¸Õ¸Õ²åÈë¼Ç¼µÄ×Ô¶¯±àºÅ String ID = "select @@IDENTITY as id"; rs = stmt.executeQuery(ID); if (rs.next()) { int autoID = rs.getInt("id"); result = autoID; } } catch (SQLException ex) { result = 0; } return result; // ·µ»Ø¸Õ¸Õ²åÈëµÄ×Ô¶¯±àºÅ } /* * ¹¦ÄÜ:¹Ø±ÕÊý¾Ý¿âµÄÁ¬½Ó */ public void close() { try { // ²¶×½Òì³£ if (rs != null) { // µ±ResultSet¶ÔÏóµÄʵÀýrs²»Îª¿Õʱ rs.close(); // ¹Ø±ÕResultSet¶ÔÏó } if (stmt != null) { // µ±Statement¶ÔÏóµÄʵÀýstmt²»Îª¿Õʱ stmt.close(); // ¹Ø±ÕStatement¶ÔÏó } if (conn != null) { // µ±Connection¶ÔÏóµÄʵÀýconn²»Îª¿Õʱ conn.close(); // ¹Ø±ÕConnection¶ÔÏó } } catch (Exception e) { e.printStackTrace(System.err); // Êä³öÒì³£ÐÅÏ¢ } } }