sqljtest.java

本套光盘提供了本书各章实例的所需的部分源程序文件以及数据库文件。读者 需要使用JDK 1.4(必需）版

import java.sql.Connection;
import java.sql.DriverManager;
import sqlj.runtime.ref.DefaultContext;
       
public class SqljTest
{
  static
  {
    try
    {
      //注册JDBC for Oracle驱动程序
      Class.forName("oracle.jdbc.driver.OracleDriver");
    }
    catch (Exception e)
    {
      e.printStackTrace();
    }
  }
       
  static Connection con;
  static DefaultContext ctx;
       
  #sql iterator NamedIterator  (String empno, String projno, int actno );
  #sql iterator PosIterator (String, String, int);
       
  public static void main (String args[]){
     SqlJDemo demoApp = new SqlJTest();
     demoApp.makeConnection();
     demoApp.insertData();
     try {

       //提交所有的事务
       #sql [ctx] {commit};

       ctx.close();
       con.close();
     } catch(java.sql.SQLException sqle) {
       sqle.printStackTrace();
     }
  }
       
  public void makeConnection()
  {
    try
    {
      // 得到连接Oracle的上下文
      ctx = DefaultContext.getDefaultContext();
      if (ctx == null)
      {
        //建立连接数据库的字段
        String url = "jdbc:oracle:thin@localhost:1521:javadb";
       
        //连接到 'javadb' 数据库用户名和密码都是'javadb'
        con = DriverManager.getConnection(url, "javadb", "javadb");
        con.setAutoCommit(false);  
       
        ctx = new DefaultContext(con);
        DefaultContext.setDefaultContext(ctx);
      }
    }
    catch(Exception e)
    {
     e.printStackTrace();
    }
  }
       
  public void insertData()
  {
    try
    {
      String empno = null;
      String projno = null;
      int actno;
       
      // 给变量赋值
      empno = "01";
      projno = "10";
      actno = 1;
       
      // 在FirstTable表中插入数据
      #sql [ctx] {INSERT INTO FirstTable (EMPNO, PROJNO, ACTNO) 
                                  values (:empno, :projno, :actno)};

      // 提交插入操作
      #sql [ctx] {commit};
    } catch(Exception e) {
      e.printStackTrace();
    }
  }
       
}