CHSHJ 发表于 2016-11-18 02:22:49

java实现连接db2数据库的代码实例

  java实现连接db2数据库的代码实例
  第一种:目前ibm一直都没有提供type 1的jdbc驱动程序。
  第二种:类型2驱动:com.ibm.db2.jdbc.app.db2driver,该驱动也位于包db2java.zip中,jdk必须能访问db2的db2jdbc.dll等。
  用法:
  class.forname("com.ibm.db2.jdbc.app.db2driver").newinstance();    string url = "jdbc:db2:sample";   connection con =drivermanager.getconnection(url, user, password);    type 2 驱动使java应用程序通过jdbc调用db2.对 db2 jdbc type 2 driver 的调用被转换成 java 本地方法。java使用这种驱动程序的应用程序必须运行在一个 db2 客户机上。jdbc 请求通过这个客户机转到 db2 服务器。
  在使用 db2 jdbc 应用程序驱动程序访问 db2 udb for iseries 数据源或者 db2 for os/390 或z/os 环境中的数据源之前,必须安装 db2 connect version 8.db2 jdbc type 2 driver 支持jdbc 1.2 规范中描述的大部分 jdbc 和 sqlj 函数,并且支持 jdbc 2.0 规范中描述的一些函数。
  第三种:类型3驱动:com.ibm.db2.jdbc.net.db2driver,该驱动位于包 db2java.zip中。
  用法:
  class.forname("com.ibm.db2.jdbc.net.db2driver").newinstance();   目标连接db2系统侦听该服务于默认端口6789 //需要在数据库教程服务器端启动db2jstrt命令,来开启网络端口。
  string url = "jdbc:db2://host:6789:sample";   connection con =drivermanager.getconnection(url, user, password);第四种:类型4驱动:com.ibm.db2.jcc.db2driver,该驱动位于包db2jcc.jar中。
  这种情况:数据库的编码为utf-8,否则报错!
  用法:
  class.forname("com.ibm.db2.jcc.db2driver").newinstance();stringurl = "jdbc:db2://host:50000/sample";   connection con =drivermanager.getconnection(url, user, password);
  import java.sql.connection;
import java.sql.drivermanager;
import java.sql.preparedstatement;
import java.sql.resultset;
import java.sql.sqlexception;
import java.sql.statement;
import java.util.arraylist;
import java.util.list;
import java.util.properties;
  public class conn {
    public static connection createconn()
    {
      connection conn=null;
      try {
            //class.forname("com.mysql教程.jdbc.driver");      
            
            
            class.forname("com.ibm.db2.jcc.db2driver").newinstance();
            string url = "jdbc:db2://www.3ppt.com:50000/sample";
            properties props教程 = new properties();
            props.setproperty("user", "db2admin");
            props.setproperty("password", "ibmdb2");
            conn=drivermanager.getconnection(url,props);
            
      }catch (classnotfoundexception e) {
            e.printstacktrace();
      } catch (instantiationexception e) {
            e.printstacktrace();
      } catch (illegalaccessexception e) {
            e.printstacktrace();
      } catch (sqlexception e) {
            e.printstacktrace();
      }
      return conn;
    }
    public static preparedstatement prepare(connection conn,string sql)
    {
      preparedstatement stat=null;
      try {
            stat=conn.preparestatement(sql);
      } catch (sqlexception e) {
            // todo auto-generated catch block
            e.printstacktrace();
      }
      return stat;
    }
   
    public static void close(connection conn)
    {
      if(conn==null) return;
      
      try {
            conn.close();
            conn=null;
      } catch (sqlexception e) {
            e.printstacktrace();
      }
    }
    public static void close(statement stat)
    {
      if(stat==null) return;
      
      try {
            stat.close();
            stat=null;
      } catch (sqlexception e) {
            e.printstacktrace();
      }
    }
    public static void close(resultset rs)
    {
      if(rs==null) return;
      try {
            rs.close();
            rs=null;
      } catch (sqlexception e) {
            e.printstacktrace();
      }
    }
    public static void main(string[] args) {
      connection conn = createconn();
      system.out.println(conn);
      string sql="(select* from db2admin.user where id not in ( select id from db2admin.userorder by id asc fetch first 10 rows only) order by id asc) fetchfirst 10 rows only";
      preparedstatement ps;
      try {
            ps = conn.preparestatement(sql);
            try {
                resultset rs=ps.executequery();
               
                while(rs.next())
                {
                  //system.out.println(rs.getstring("usercount"));//(1);//.getstring("name"));
                  
                  system.out.println(rs.getstring("id"));
                  system.out.println(rs.getstring("name"));
                  system.out.println(rs.getstring("password"));
                }
            } catch (sqlexception e) {
                e.printstacktrace();
            }
            conn.close();
            ps.close();
      } catch (sqlexception e1) {
            // todo auto-generated catch block
            e1.printstacktrace();
      }
    }
}
  java常用数据库字符串连接
  1.mysql(http://www.mysql.com)mm.mysql-2.0.2-bin.jar
  class.forname("org.gjt.mm.mysql.driver");
  cn=drivermanager.getconnection("jdbc:mysql://mydbcomputernameorip:3306/mydatabasename",susr,spwd);
  2.postgresql(http://www.de.postgresql.org)pgjdbc2.jar
  class.forname("org.postgresql.driver");
  cn=drivermanager.getconnection("jdbc:postgresql://mydbcomputernameorip/mydatabasename",susr,spwd);
页: [1]
查看完整版本: java实现连接db2数据库的代码实例