dbado.java~1~

来自「Java数据库系统开发实例导航的例子」· JAVA~1~ 代码 · 共 134 行

package com.officelog;

import java.sql.*;
import java.io.*;


/**
 * <p>Title: INation Club Access Data Object for qa function</p>
 * <p>Description: INation Club Access Data Object for qa function</p>
 * <p>Copyright: Copyright (c) 2002</p>
 * <p>Company: ibm</p>
 * @author yanglan
 * @version 1.0
 */

public class DbADO {

   Connection  conn=null;
   Statement  stmt=null;
   ResultSet  rs=null;
    public DbADO() {  }


 public boolean connect()
 {
       
       boolean isConnect=false;
  try 
  {
           Class.forName("COM.ibm.db2.jdbc.app.DB2Driver").newInstance(); 
           String  url="jdbc:db2:OFFLOG";  
            //OFFLOG为你的数据库名  
           String  dbuser="db2admin";  
           String  dbpassword="clarion"; 
            
           conn=  DriverManager.getConnection(url,dbuser,dbpassword);  
           
           if (conn!=null)
                 isConnect=true;
           
   }
   catch(Exception e)
   {
             System.out.println("connect to database failed");
             e.printStackTrace();
   }
   
   return isConnect;

 }
      
  public void close()
  {
      try{
      	  if(rs!=null)
             rs.close();
             
          rs=null;
          
          if(stmt!=null)
             stmt.close();
          
          stmt=null;
          
          if(conn!=null)
      	       conn.close();
          
      }
      catch(Exception e)
      {
         e.printStackTrace();
      }
      finally
      {
      	     
             conn = null;
      }
      
   }


   public ResultSet select(String sql)
  {
          try{
          	
          	stmt = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);
           	rs=stmt.executeQuery(sql);           
          	            
           }
          catch(Exception e)
          {
            e.printStackTrace();
          }
          return rs;
  }
  
   public int update_insert(String sql)
  {
        int num=0;
        try{
        	 stmt = conn.createStatement(); 
        	 stmt.executeUpdate(sql);
        	             
        }
        catch(Exception e)
        {
          e.printStackTrace();
        }
        return num;

  }
  
  public int total(String sql)
  {
          int num=0;
          
          try{
          	stmt = conn.createStatement();   
          	rs=stmt.executeQuery(sql);  
            
            while(rs.next())
            {
            	 num=rs.getInt(1);
             }
            
           }
          catch(Exception e)
          {
            e.printStackTrace();
          }
          return num;
  }
  
  }