?? dbconnection.java
字號:
package espc;import java.io.*;import java.sql.*;import java.util.Properties;public class DbConnection{ Connection conn=null; Statement stmt=null; ResultSet rset=null; //構造方法 public DbConnection() { } public boolean openConnection() { //----------------------------------------------------------------- //裝載數據庫的Property文件:其中包括數據庫驅動,數據庫URL,即用戶ID和密碼 //----------------------------------------------------------------- Properties prop = new Properties(); try { InputStream is = getClass().getResourceAsStream("Db.properties"); prop.load(is); if(is != null) is.close(); } catch(IOException e) { System.out.println("[DbConnection]打開文件時出現錯誤!"); } //----------------------------------------------------------- //從property文件中讀出數據庫Property //----------------------------------------------------------- String jdbc = prop.getProperty("drivers"); String url = prop.getProperty("url"); String user = prop.getProperty("user"); String password = prop.getProperty("password"); //----------------------------------------------------------- //將輸入的property輸出到Debugging //----------------------------------------------------------- System.out.println(String.valueOf(String.valueOf((new StringBuffer("jdbc=[")).append(jdbc).append("]")))); System.out.println(String.valueOf(String.valueOf((new StringBuffer("url=[")).append(url).append("]")))); System.out.println(String.valueOf(String.valueOf((new StringBuffer("user=[")).append(user).append("]")))); System.out.println(String.valueOf(String.valueOf((new StringBuffer("password=[")).append(password).append("]")))); //----------------------------------------------------------- //加載jdbc驅動 //----------------------------------------------------------- try { Class.forName(jdbc); System.out.println("驅動程序加載成功!"); } catch(ClassNotFoundException e) { System.out.println("JDBC登陸過程中出現錯誤".concat(String.valueOf(String.valueOf(e.getMessage())))); boolean flag = false; return flag; } //----------------------------------------------------------- //打開數據庫connection //----------------------------------------------------------- try { conn = DriverManager.getConnection(url, user, password); System.out.println("數據庫連接成功!!"); } catch(SQLException e) { System.out.println("數據庫連接過程中出現錯誤".concat(String.valueOf(String.valueOf(e.getMessage())))); boolean flag1 = false; return flag1; } return true; } /**************************************************************************** *方法名稱:executeQuery *參數:query(SQL查詢語句) *返回值類型:java.sql.ResultSet *說明:查詢數據庫的方法(SELECT) ****************************************************************************/ public ResultSet executeQuery(String query) throws SQLException { stmt = conn.createStatement(); rset = stmt.executeQuery(query); return rset; } /**************************************************************************** *方法名稱:executeUpdate *參數:query(SQL查詢語句) *返回值類型:void *說明:查詢數據庫的方法(UPDATE,DELETE,INSERT) ****************************************************************************/ public void executeUpdate(String query) throws SQLException { stmt = conn.createStatement(); stmt.executeUpdate(query); if(stmt != null) stmt.close(); } /**************************************************************************** *方法名稱:close *參數:無 *返回值類型:void *說明:返回數據庫鏈接的相關資料 ****************************************************************************/ public void close() throws SQLException { if(conn != null) conn.close(); if(rset != null) rset.close(); if(stmt != null) stmt.close(); } /**************************************************************************** *方法名稱:finalize *參數:無 *返回值類型:void *說明:從服務器回收資源 ****************************************************************************/ protected void finalize() throws Throwable { close(); }/* public static void main(String[] s) throws java.lang.InstantiationException,java.lang.IllegalAccessException{ DbConnection con=new DbConnection(); con.openConnection(); try{ ResultSet rs=con.executeQuery("select * from user_info"); //rs.afterLast(); while(rs.next()){ System.out.println(rs.getString(1)); System.out.println("目前的行數"+rs.getRow()); } // System.out.println("目前的行數"+rs.absolute(1)); // con.close(); System.out.print("end"); } catch(SQLException e){System.out.print(e.toString());} }*/}
?? 快捷鍵說明
復制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -