Chinaunix首页 | 论坛 | 博客
  • 博客访问: 1471775
  • 博文数量: 254
  • 博客积分: 8696
  • 博客等级: 中将
  • 技术积分: 2961
  • 用 户 组: 普通用户
  • 注册时间: 2008-04-03 16:46
文章分类

全部博文(254)

文章存档

2015年(4)

2014年(18)

2013年(16)

2012年(8)

2011年(25)

2010年(2)

2009年(74)

2008年(107)

分类: Mysql/postgreSQL

2008-07-06 15:08:35

package dg.tool;

import java.sql.*;

public class SqlOperation {
   /**设置数据库连接用户名*/
   private String userName = "root";
   /**设置数据库连接密码*/
   private String pwd = "";
   /**设置数据库*/
   private String database = "dogo";
   /**设置JDBC驱动程序*/
   private String dbDriver = "org.gjt.mm.mysql.Driver";
   /**设置数据库URL*/
   private String dbConnect = "jdbc:mysql://localhost/" + database+"?useUnicode=true&characterEncoding=GBK";
   private Connection conn = null;
   private Statement stmt = null;
   ResultSet rs = null;

   //数据库驱动程序注册
   public SqlOperation() {
     try{
       Class.forName(dbDriver);
     }
     catch(java.lang.ClassNotFoundException e){
       System.err.println("jdbcDriver Error!");
     }
   }

   /**建立数据库连接及定义数据查询*/
   public ResultSet executeQuery(String sql) throws SQLException{
     rs = null;
     try{
       conn = DriverManager.getConnection(dbConnect,userName,pwd);
       stmt = conn.createStatement();
       rs = stmt.executeQuery(sql);
     }
     catch(SQLException ex){
       throw new SQLException("executeQuery wrong!!!");
     }
     return rs;
   }

   /**建立数据库连接及定义数据操作*/
   public void executeUpdate(String sql) throws SQLException{
     stmt = null;

     try {
       conn = DriverManager.getConnection(dbConnect,userName,pwd);
       stmt = conn.createStatement();
       stmt.executeUpdate(sql);
     }
     catch(SQLException ex){
       throw new SQLException("executeUpdate wrong!!!");
     }
     finally{
       stmt.close();
       conn.close();
     }
   }

   /**关闭陈述语句*/
   public void closeStmt(){
     try{
       stmt.close();
     }
     catch(SQLException e){
       System.err.println("closeStmt Error!");
     }
   }

   /**关闭连接*/
   public   void closeConn(){
     try{
       conn.close();
     }
     catch(SQLException e){
       System.err.println("closeConn Error!");
     }
   }

   /**字符串进行转码*/
   public String toGb(String str) {
     String finallStr = null;
     try {
           finallStr = new String(str.getBytes("ISO8859-1"),"GB2312");
     }
     catch(Exception ex) {
            System.out.println(ex);
          }
     return finallStr;
     }

}

阅读(2102) | 评论(0) | 转发(0) |
给主人留下些什么吧!~~