DBConnection.java
上传用户:sdtxjx
上传日期:2022-07-09
资源大小:2937k
文件大小:5k
源码类别:

Jsp/Servlet

开发平台:

Java

  1. /***************************************************
  2.  *  
  3.  *  源文件名:  DBConnecion.java
  4.  *  功    能: 梦想年华新闻系统 - 数据库连接类
  5.  * 作者:梦想年华 [DreamTime]
  6.  * Email:fanwsp@126.com
  7.  *  QQ:122142023 
  8.  *  CopyRight(c)2005-2006 by DreamTime 
  9.  *
  10.  ****************************************************
  11. */
  12. package dreamtime.dreamnews; //指定类所在的包
  13. import java.sql.*; //导入数据库操作的类
  14. import java.util.*;
  15. import java.io.*;
  16. public class DBConnection
  17. {
  18.     private String FileName; //配置文件名
  19.     private int DBType; //数据库类型
  20.    
  21.     private Connection conn; //连接对象
  22. private Statement stmt; //语句对象
  23. private ResultSet rs; //结果集对象
  24.     private String AccessDriver; //保存Access驱动程序
  25.     private String AccessURL;  //保存Access连接字符串
  26.     private String AccessPath;  //保存Access数据库的路径
  27.     
  28.     private String MySqlDriver; //MYSQL Server驱动程序
  29.     private String MySqlURL;  //MYSQL Server连接字符串
  30.         
  31.     private String SqlDriver; //SQL Server驱动程序
  32.     private String SqlURL;  //SQL Server连接字符串
  33.     
  34.     private String OracleDriver; //Oracle驱动程序
  35.     private String OracleURL;  //Oracle连接字符串
  36.     
  37.     
  38.     public DBConnection()
  39.     {
  40.      conn = null;
  41.     }
  42. public  Connection getConn()
  43. {
  44. DBType= new Function().StrToInt(getPara("DBType"));
  45. switch(DBType)
  46. {
  47. case 0:return(getConnToAccess());
  48. case 1:return(getConnToMySql());
  49. case 2:return(getConnToSql());
  50. case 3:return(getConnToOracle());
  51. default:return null;
  52. }
  53. }
  54. public String getPara(String ParaName) 
  55. {
  56. FileName="../../DBConfig.property";
  57. Properties prop= new Properties();
  58. try
  59. {
  60. InputStream is = getClass().getResourceAsStream(FileName);
  61. prop.load(is);
  62. if(is!=null) is.close();
  63. }
  64. catch(Exception e) {
  65. return "Error!";
  66. }
  67. return prop.getProperty(ParaName);
  68. }
  69.     public Connection getConnToAccess()
  70.     {
  71. try{
  72.      AccessDriver = getPara("AccessDriver");
  73.      AccessURL = getPara("AccessURL");
  74.      AccessPath = getPara("AccessPath");
  75. AccessURL=AccessURL+AccessPath;
  76.      Class.forName(AccessDriver).newInstance();
  77.      conn = DriverManager.getConnection(AccessURL);
  78.      }catch(Exception e){
  79.      //e.printStackTrace();
  80.      //return "操作数据库出错,请仔细检查" ;
  81.      //System.err.println(e.getMessage());
  82.      }
  83.     return conn;
  84.     }
  85.      
  86.      
  87.     public Connection getConnToMySql()
  88.     {
  89. try{
  90.   MySqlDriver = getPara("MySQLDriver");
  91.      MySqlURL = getPara("MySQLURL");
  92.      Class.forName(MySqlDriver).newInstance();
  93.      conn = DriverManager.getConnection(MySqlURL);
  94.      }catch(Exception e){
  95.      //e.printStackTrace();
  96.      //return "操作数据库出错,请仔细检查" ;
  97.      //System.err.println(e.getMessage());
  98.      }
  99.     return conn;
  100.     } 
  101.     
  102.  
  103. public Connection getConnToSql()
  104. {     
  105.       try{
  106.       SqlDriver = getPara("SQLDriver");
  107.          SqlURL = getPara("SQLURL");
  108.      Class.forName(SqlDriver).newInstance();
  109.      conn = DriverManager.getConnection(SqlURL);
  110.      }catch(Exception e){
  111.      e.printStackTrace();
  112.      //return "操作数据库出错,请仔细检查" ;
  113.      //System.err.println(e.getMessage());
  114.      }
  115.     return conn;
  116.     }
  117.     
  118.  
  119.     public Connection getConnToOracle()
  120.     {     
  121. try{
  122.   OracleDriver = getPara("OracleDriver");
  123.      OracleURL = getPara("OracleURL");
  124.      Class.forName(OracleDriver).newInstance();
  125.      conn = DriverManager.getConnection(OracleURL);
  126.      }catch(Exception e){
  127.      //e.printStackTrace();
  128.      //return "操作数据库出错,请仔细检查" ;
  129.      //System.err.println(e.getMessage());
  130.      }
  131.     return conn;
  132.     }
  133.     
  134.     
  135.    //关闭数据库连接
  136.    /* public void Close()
  137.     {
  138.         try{
  139.             Conn.close(); 
  140.         }catch(SQLException sqlexception){
  141.             sqlexception.printStackTrace();
  142.         }
  143.     }*/
  144.     
  145.     
  146.     public static void main(String[] args)
  147. {
  148. DBConnection DBConn = new DBConnection();
  149. try
  150. {
  151. Connection Conn = DBConn.getConn();
  152. ResultSet rs = null;
  153. Statement stmt = Conn.createStatement(1004,1007);
  154.      String Sql = "select * from Admin where AdminName='dream' and AdminPwd='dream'";
  155.      rs = stmt.executeQuery(Sql);
  156.      rs.next();
  157.      if (!rs.isAfterLast()) 
  158. {
  159. System.out.println(rs.getString("AdminName")+"登录成功!");
  160. }
  161. else
  162. {
  163. System.out.println("登录失败!");
  164. }
  165. }
  166. catch(SQLException e)
  167. {
  168. System.out.println(e.getMessage().toString());
  169. }
  170. }
  171.     
  172. }