records.java

weblogic应用全实例

//声明本类包含在包examples.jdbc.informix4中
package examples.jdbc.informix4;
//声明本类要引入的其他包和类
import java.sql.*;
import java.util.Properties;

/**
 *
 * 这个简单的实例演示JDBC如何用来执行DDL和DML。要求表empdemo存在。
 * 可以使用simplesql实例创建。
 */

public class records {
  
  public static void main(String argv[])
  {
  //声明连接和PreparedStatement变量
    java.sql.Connection conn = null;
    java.sql.PreparedStatement pstmt = null;
    java.sql.PreparedStatement pstmt2 = null;
    try {
	//属性对象赋值
      Properties props = new Properties();
      props.put("user",     "informix");
      props.put("password", "secret");
      props.put("server",   "myDBHost"); //Informix服务器运行的主机名
      props.put("port",     "1493"); // Informix服务器的监听端口
      props.put("db",       "myDB"); // Informix服务器数据库名
      //加载驱动程序
      Driver myDriver = (Driver) Class.forName("weblogic.jdbc.informix4.Driver").newInstance();
      //建立连接
      conn = myDriver.connect("jdbc:weblogic:informix4", props);
    
      // 插入 100个记录
      System.out.println("Inserting 100 records...");
      String inssql = "insert into empdemo(empid, name, dept) values (?, ?, ?)";
      pstmt = conn.prepareStatement(inssql);
      //执行插入100个记录
      for (int i = 0; i < 100; i++) {
        pstmt.setInt(1, i);
        pstmt.setString(2, "Person " + i);
        pstmt.setInt(3, i);
        pstmt.execute();
      }
      //关闭
      pstmt.close();
    
      // 更新100 个记录
      System.out.println("Updating 100 records...");
      String updsql = "update empdemo set dept = dept + ? where empid = ?";
      pstmt2 = conn.prepareStatement(updsql);
      //执行
      for (int i = 0; i < 100; i++) {
        pstmt2.setInt(1, i);
        pstmt2.setInt(2, i);
        pstmt2.execute();
      }

      // 如果这个数据库每处在自动释放模式, 则释放连接
      if (!conn.getAutoCommit()) {
        conn.commit();
      }
    } catch (Exception e) {
    	//异常抛出时
        System.out.println("Caught Exception: " + e.getMessage());
    } finally {
    	//关闭连接
        try {
          if (pstmt != null)
            pstmt.close();
          if (pstmt2 != null)
            pstmt2.close();
          if (conn != null)
            conn.close();
        } catch (SQLException sqle) {
            System.out.println("SQLExcepion was thrown: " + sqle.getMessage());
        }
    }
  } 
}