dbado.java

Java数据库系统开发实例导航的例子

package com.officelog;

import java.sql.*;
import java.io.*;
import COM.ibm.db2.jdbc.app.DB2Driver;

/**
 * <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;
  }

  }