records.java

weblogic应用全实例

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

/**
 *  这个简单的实例演示JDBC如何用来执行DDL和DML。假定表empdemo存在，可以在simplesql实例中创建。
 */
public class records {
  
    public static void main(String argv[])
  {
  //声明连接，SQL语句
    java.sql.Connection conn          = null;
    java.sql.PreparedStatement pstmt  = null;
    java.sql.PreparedStatement pstmt2 = null;
    
    try {
    //声明属性变量		
      Properties props = new Properties();
      props.put("user","scott");
      props.put("password","tiger");
      props.put("server","DEMO");
      //加载数据库驱动程序weblogic.jdbc.oci.Driver
      Driver myDriver = (Driver)Class.forName("weblogic.jdbc.oci.Driver").newInstance();
      //创建连接，连接数据库jdbc:weblogic:oracle
      conn = myDriver.connect("jdbc:weblogic:oracle", props);
      
      // 设置自动释放属性，这会提高性能
      conn.setAutoCommit(false);
      
      // 插入100个记录
      System.out.println("Inserting 100 records...");
      String inssql = "insert into empdemo(empid, name, dept) values (?, ?, ?)";
      //获取PreparedStatement对象
      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();
      }
      
      // 更新100个记录
      System.out.println("Updating 100 records...");
      String updsql = "update empdemo set dept = dept + ? where empid = ?";
      pstmt2 = conn.prepareStatement(updsql);
      //执行更新100个记录
      for (int i = 0; i < 100; i++) {
          pstmt2.setInt(1, i);
          pstmt2.setInt(2, i);
          pstmt2.execute();
      }
      //释放连接
      conn.commit();
    } catch (Exception e) {
    //异常处理
        System.out.println("Exception was thrown: " + 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("SQLException was thrown: " + sqle.getMessage());
        }
    }
  }
}