ConnDB.java~33~
上传用户: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.     //说明:此处需要配置web.xml文件
  10.     public ConnDB() {   //构造方法
  11.     }
  12.     public Connection getConnection() {
  13.       try {
  14.           Class.forName(proxool);
  15.           conn = DriverManager.getConnection(poolname);
  16.       } catch (ClassNotFoundException e) {
  17.           System.out.println(e.getMessage());
  18.       } 
  19.       if (conn == null) {
  20.           System.out.println("没有获取到数据库连接");
  21.       }
  22.       return conn;
  23.     }
  24.     /*
  25.  *功能:执行查询语句
  26.  */
  27. public ResultSet executeQuery(String sql) {
  28.   try {
  29.     conn = getConnection();
  30.     stmt = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,
  31.                                 ResultSet.CONCUR_READ_ONLY);
  32.     rs = stmt.executeQuery(sql);
  33.   }
  34.   catch (SQLException ex) {
  35.     System.err.println(ex.getMessage());
  36.   }
  37.   return rs;
  38. }
  39. /*
  40.  *功能:执行更新操作
  41.  */
  42. public int executeUpdate(String sql) {
  43.   int result = 0;
  44.   try {
  45.     conn = getConnection();
  46.     stmt = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,
  47.                                 ResultSet.CONCUR_READ_ONLY);
  48.     result = stmt.executeUpdate(sql);
  49.   }
  50.   catch (SQLException ex) {
  51.     result = 0;
  52.   }
  53.   try {
  54.     stmt.close();
  55.   }
  56.   catch (SQLException ex1) {
  57.   }
  58.   return result;
  59. }
  60. public int executeUpdate_id(String sql) {
  61.   int result = 0;
  62.   try {
  63.     conn = getConnection();
  64.     stmt = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,
  65.                                 ResultSet.CONCUR_READ_ONLY);
  66.     result = stmt.executeUpdate(sql);
  67.     String ID = "select @@IDENTITY as id";
  68.     rs = stmt.executeQuery(ID);
  69.     if (rs.next()) {
  70.       int autoID = rs.getInt("id");
  71.       result = autoID;
  72.     }
  73.   }
  74.   catch (SQLException ex) {
  75.     result = 0;
  76.   }
  77.   return result;
  78. }
  79.     /*
  80.      *功能:关闭数据库的连接
  81.      */
  82.     public void close() {
  83.       try {
  84.         if (rs != null) {
  85.           rs.close();
  86.         }
  87.       }
  88.       catch (Exception e) {
  89.         e.printStackTrace(System.err);
  90.       }
  91.       try {
  92.         if (stmt != null) {
  93.           stmt.close();
  94.         }
  95.       }
  96.       catch (Exception e) {
  97.         e.printStackTrace(System.err);
  98.       }
  99.       try {
  100.         if (conn != null) {
  101.           conn.close();
  102.         }
  103.       }
  104.       catch (Exception e) {
  105.         e.printStackTrace(System.err);
  106.       }
  107.   }
  108. }