欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

Java编程中使用JDBC API连接数据库和创建程序的方法

程序员文章站 2024-03-31 19:46:46
jdbc连接数据库 涉及到建立一个jdbc连接的编程是相当简单的。下面是这些简单的四个步骤: 导入jdbc包: 添加import语句到java程序导入所需的类在...

jdbc连接数据库

涉及到建立一个jdbc连接的编程是相当简单的。下面是这些简单的四个步骤:

  1. 导入jdbc包: 添加import语句到java程序导入所需的类在java代码中。
  2. 注册jdbc驱动程序:这一步会导致jvm加载所需的驱动程序实现到内存中,因此它可以实现jdbc请求。
  3. 数据库url制定:这是创建格式正确的地址指向到要连接的数据库。
  4. 创建连接对象:最后,代码调用drivermanager对象的getconnection()方法来建立实际的数据库连接。

导入jdbc包:
import 语句告诉java编译器在哪里可以找到在代码中引用,并放置在您的源代码最开始的类。

使用标准的jdbc包,它允许选择,插入,更新和sql表中删除数据,添加以下进口到您的源代码:

import java.sql.* ; // for standard jdbc programs
import java.math.* ; // for bigdecimal and biginteger support

注册jdbc驱动程序:
使用它之前,必须注册你的驱动程序在程序。注册驱动程序是由oracle驱动程序的类文件被加载到内存中以便它可以被用作jdbc接口的实现过程。

需要做这个注册只能在你的程序一次。可以通过以下两种方式之一注册一个驱动程序。

方法(i)- class.forname():
注册一个驱动程序中最常用的方法是使用java的class.forname()方法来动态加载驱动程序的类文件到内存中,它会自动将其注册。这种方法是可取的,因为它允许使驱动注册配置,便于携带。

下面的示例使用class.forname()来注册oracle驱动程序:

try {
  class.forname("oracle.jdbc.driver.oracledriver");
}
catch(classnotfoundexception ex) {
  system.out.println("error: unable to load driver class!");
  system.exit(1);
}

可以使用getinstance()方法来解决不兼容的jvm,但要编写了两个额外的例外情况如下:

try {
  class.forname("oracle.jdbc.driver.oracledriver").newinstance();
}
catch(classnotfoundexception ex) {
  system.out.println("error: unable to load driver class!");
  system.exit(1);
catch(illegalaccessexception ex) {
  system.out.println("error: access problem while loading!");
  system.exit(2);
catch(instantiationexception ex) {
  system.out.println("error: unable to instantiate driver!");
  system.exit(3);
}

方法(二) - drivermanager.registerdriver():
可以用它来注册一个驱动程序的第二种方法是使用staticdrivermanager.registerdriver()方法。

应该,如果使用的是不兼容的jdk jvm,比如微软提供一个使用registerdriver()方法。

下面的示例使用registerdriver()来注册oracle驱动程序:

try {
  driver mydriver = new oracle.jdbc.driver.oracledriver();
  drivermanager.registerdriver( mydriver );
}
catch(classnotfoundexception ex) {
  system.out.println("error: unable to load driver class!");
  system.exit(1);
}

数据库url制定:
当加载的驱动程序,可以建立程序中使用drivermanager.getconnection()方法的连接。为方便参考,让列出了三个重载drivermanager.getconnection()方法:

  1. getconnection(string url)
  2. getconnection(string url, properties prop)
  3. getconnection(string url, string user, string password)

在这里,每个表单需要一个数据库url。数据库的url是指向数据库地址。

制定一个数据库url是大多数用在建立连接相关。

下表列出了下来流行的jdbc驱动程序名和数据库的url。

rdbms jdbc驱动程序的名称 url 格式

mysql com.mysql.jdbc.driver jdbc:mysql://hostname/ databasename
oracle oracle.jdbc.driver.oracledriver jdbc:oracle:thin:@hostname:port number:databasename
db2 com.ibm.db2.jdbc.net.db2driver jdbc:db2:hostname:port number/databasename
sybase com.sybase.jdbc.sybdriver jdbc:sybase:tds:hostname: port number/databasename

以url格式所有高亮的部分是静态的,需要改变只剩余部分按照数据库设置。

创建连接对象: 使用数据库url的用户名和密码:
下面三种形式drivermanager.getconnection()方法来创建一个连接对象。getconnection()最常用形式要求传递一个数据库url,用户名 username和密码 password:

对url数据库部分databasename的值:假设使用的是oracle的瘦驱动程序,需要指定一个主机:端口。

假设有一台主机tcp/ip地址192.0.0.1 以及主机名和oracle监听器被配置为在端口1521,数据库名称是emp,然后完整的数据库url是:

jdbc:oracle:thin:@amrood:1521:emp

现在,必须调用适当的用户名和密码以及getconnection()方法来获得一个connection对象,如下所示:

string url = "jdbc:oracle:thin:@amrood:1521:emp";
string user = "username";
string pass = "password"
connection conn = drivermanager.getconnection(url, user, pass);

只使用一个数据库url:
第二种形式 drivermanager.getconnection()方法只需要一个数据库url:

drivermanager.getconnection(string url);

然而,在这种情况下,数据库的url,包括用户名和密码,并具有以下的一般形式:

jdbc:oracle:driver:username/password@database

所以上面的连接可以创建如下:

string url = "jdbc:oracle:thin:username/password@amrood:1521:emp";
connection conn = drivermanager.getconnection(url);

使用数据库的url和一个properties对象:
第三种形式drivermanager.getconnection()方法需要一个数据库url和一个properties对象:

drivermanager.getconnection(string url, properties info);
properties对象,保存一组关键字 - 值对。它被用来调用getconnection()方法时驱动程序属性传递给驱动程序。

为了使通过前面的例子中所做的相同的连接,使用下面的代码:

import java.util.*;

string url = "jdbc:oracle:thin:@amrood:1521:emp";
properties info = new properties( );
info.put( "user", "username" );
info.put( "password", "password" );

connection conn = drivermanager.getconnection(url, info);

关闭jdbc连接:
在jdbc程序的结束,它明确要求关闭所有的连接到数据库,以结束每个数据库会话。但是,如果忘了,java垃圾收集器会关闭连接时,它会清除陈旧的对象。

依托垃圾收集,特别是在数据库编程,是非常差的编程习惯。应该总是在关闭与连接对象关联的close()方法连接的习惯。

为了确保连接被关闭,可以在代码中的finally块执行。 finally块都会执行,不管是否发生或也不例外。

要关闭上面打开的连接,应该调用close()方法,如下所示:

conn.close();
显式地关闭连接dbms节约资源。


创建jdbc应用程序:
有下列涉及构建jdbc应用程序的六个步骤:

  1. 导入数据包 . 需要包括含有需要进行数据库编程的jdbc类的包。大多数情况下,使用 import java.sql.*  就可以了.
  2. 注册jdbc驱动程序. 需要初始化驱动程序,可以与数据库打开一个通信通道。
  3. 打开连接. 需要使用drivermanager.getconnection() 方法创建一个connection对象,它代表与数据库的物理连接。
  4. 执行查询 . 需要使用类型声明的对象建立并提交一个sql语句到数据库。
  5. 从结果集中提取数据 . 要求使用适当的关于resultset.getxxx()方法来检索结果集的数据。
  6. 清理环境. 需要明确地关闭所有的数据库资源相对依靠jvm的垃圾收集。

示例代码:
这个范例的例子可以作为一个模板,在需要建立jdbc应用程序。

基于对环境和数据库安装在前面的章节中做此示例代码已写入。

复制下面的例子firstexample.java,编译并运行,如下所示:

//step 1. import required packages
import java.sql.*;

public class firstexample {
  // jdbc driver name and database url
  static final string jdbc_driver = "com.mysql.jdbc.driver"; 
  static final string db_url = "jdbc:mysql://localhost/emp";

  // database credentials
  static final string user = "username";
  static final string pass = "password";
  
  public static void main(string[] args) {
  connection conn = null;
  statement stmt = null;
  try{
   //step 2: register jdbc driver
   class.forname("com.mysql.jdbc.driver");

   //step 3: open a connection
   system.out.println("connecting to database...");
   conn = drivermanager.getconnection(db_url,user,pass);

   //step 4: execute a query
   system.out.println("creating statement...");
   stmt = conn.createstatement();
   string sql;
   sql = "select id, first, last, age from employees";
   resultset rs = stmt.executequery(sql);

   //step 5: extract data from result set
   while(rs.next()){
     //retrieve by column name
     int id = rs.getint("id");
     int age = rs.getint("age");
     string first = rs.getstring("first");
     string last = rs.getstring("last");

     //display values
     system.out.print("id: " + id);
     system.out.print(", age: " + age);
     system.out.print(", first: " + first);
     system.out.println(", last: " + last);
   }
   //step 6: clean-up environment
   rs.close();
   stmt.close();
   conn.close();
  }catch(sqlexception se){
   //handle errors for jdbc
   se.printstacktrace();
  }catch(exception e){
   //handle errors for class.forname
   e.printstacktrace();
  }finally{
   //finally block used to close resources
   try{
     if(stmt!=null)
      stmt.close();
   }catch(sqlexception se2){
   }// nothing we can do
   try{
     if(conn!=null)
      conn.close();
   }catch(sqlexception se){
     se.printstacktrace();
   }//end finally try
  }//end try
  system.out.println("goodbye!");
}//end main
}//end firstexample

现在来编译上面的例子如下:

c:>javac firstexample.java

当运行firstexample,它会产生以下结果:

c:>java firstexample
connecting to database...
creating statement...
id: 100, age: 18, first: zara, last: ali
id: 101, age: 25, first: mahnaz, last: fatma
id: 102, age: 30, first: zaid, last: khan
id: 103, age: 28, first: sumit, last: mittal