simplesql.java

weblogic应用全实例

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

/**
 * 这个实例演示怎样使用JDBC执行DDL和DML。
 */

public class simplesql {
    
    public static void main(String argv[])
    {
    //声明连接，SQL语句变量	
      java.sql.Connection conn = null;
      java.sql.Statement stmt  = 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);
     //创建SQL语句对象
        stmt = conn.createStatement();
      
        try {
        //删除表empdemo
            stmt.execute("drop table empdemo");
            System.out.println("Table empdemo dropped.");
        }
        catch (SQLException e) {
        
          // 表empdemo不需要删除
        }
       //创建表empdemo
        stmt.execute("create table empdemo (empid integer, name varchar(30), dept float(4))");
        System.out.println("Table empdemo created.");
       //插入记录
        int numrows = stmt.executeUpdate("insert into empdemo values (0, 'John Smith', 12)");
        System.out.println("Number of rows inserted = " + numrows);
      //删除条件为empid = 0的记录
        numrows = stmt.executeUpdate("delete from empdemo where empid = 0");
        System.out.println("Number of rows deleted = " + numrows);
      
        // 如果数据库不具自动释放模式, 则释放连接
        if (!conn.getAutoCommit()) {
            conn.commit();
        }
      } catch (Exception e) {
      	//抛出异常
          System.out.println("Exception was thrown: " + e.getMessage());
      } finally {
      	//关闭资源
          try {
            if (stmt != null)
              stmt.close();
            if (conn != null)
              conn.close();
          } catch (SQLException sqle) {
              System.out.println("SQLException was thrown: " + sqle.getMessage());
          }
      }
  }
}