ConnDB.java~31~
上传用户:toby828
上传日期:2015-06-26
资源大小:8558k
文件大小:3k
源码类别:

Jsp/Servlet

开发平台:

Java

  1. package com.core;
  2. import java.sql.*;
  3. public class ConnDB {
  4.     public Connection conn=null;
  5.     public ResultSet rs=null;
  6.     public Statement stmt=null;
  7.     private String proxool = "org.logicalcobwebs.proxool.ProxoolDriver";
  8.     private String poolname = "proxool.library";
  9.     public Connection getConnection() {
  10.       try {
  11.           Class.forName(proxool);
  12.           conn = DriverManager.getConnection(poolname);
  13.       } catch (ClassNotFoundException e) {
  14.           System.out.println(e.getMessage());
  15.       } catch (SQLException e) {
  16.           System.out.println(e.getMessage());
  17.       }
  18.       if (conn == null) {
  19.           System.out.println("没有获取到数据库连接");
  20.       }
  21.       return conn;
  22.     }
  23.     /*
  24.  *功能:执行查询语句
  25.  */
  26. public ResultSet executeQuery(String sql) {
  27.   try {
  28.     conn = getConnection();
  29.     stmt = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,
  30.                                 ResultSet.CONCUR_READ_ONLY);
  31.     rs = stmt.executeQuery(sql);
  32.   }
  33.   catch (SQLException ex) {
  34.     System.err.println(ex.getMessage());
  35.   }
  36.   return rs;
  37. }
  38. /*
  39.  *功能:执行更新操作
  40.  */
  41. public int executeUpdate(String sql) {
  42.   int result = 0;
  43.   try {
  44.     conn = getConnection();
  45.     stmt = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,
  46.                                 ResultSet.CONCUR_READ_ONLY);
  47.     result = stmt.executeUpdate(sql);
  48.   }
  49.   catch (SQLException ex) {
  50.     result = 0;
  51.   }
  52.   try {
  53.     stmt.close();
  54.   }
  55.   catch (SQLException ex1) {
  56.   }
  57.   return result;
  58. }
  59. public int executeUpdate_id(String sql) {
  60.   int result = 0;
  61.   try {
  62.     conn = getConnection();
  63.     stmt = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,
  64.                                 ResultSet.CONCUR_READ_ONLY);
  65.     result = stmt.executeUpdate(sql);
  66.     String ID = "select @@IDENTITY as id";
  67.     rs = stmt.executeQuery(ID);
  68.     if (rs.next()) {
  69.       int autoID = rs.getInt("id");
  70.       result = autoID;
  71.     }
  72.   }
  73.   catch (SQLException ex) {
  74.     result = 0;
  75.   }
  76.   return result;
  77. }
  78.     /*
  79.      *功能:关闭数据库的连接
  80.      */
  81.     public void close() {
  82.       try {
  83.         if (rs != null) {
  84.           rs.close();
  85.         }
  86.       }
  87.       catch (Exception e) {
  88.         e.printStackTrace(System.err);
  89.       }
  90.       try {
  91.         if (stmt != null) {
  92.           stmt.close();
  93.         }
  94.       }
  95.       catch (Exception e) {
  96.         e.printStackTrace(System.err);
  97.       }
  98.       try {
  99.         if (conn != null) {
  100.           conn.close();
  101.         }
  102.       }
  103.       catch (Exception e) {
  104.         e.printStackTrace(System.err);
  105.       }
  106.   }
  107. }