create table testtable (
  id integer not null,
  name char(20) not null,
  age smallint not null,
  address char(74) not null )
  partitioning key (id);
alter table testtable add primary key(id);

                
db2profc -user=dbuser -password=dbpwd -url=jdbc:db2:dbname -prepoptions=
"bindfile using TestTableInserter.bnd package using TTblIns insert buf"
TestTableInserter_SJProfile0.ser

                
1	{
2	sqlj.runtime.ConnectionContext __sJT_connCtx = _defaultContext;
3	if (__sJT_connCtx == null) sqlj.runtime.error.RuntimeRefErrors.raise_NULL_CONN_CTX();
4	sqlj.runtime.ExecutionContext __sJT_execCtx = _executionContext;
5	if (__sJT_execCtx == null) sqlj.runtime.error.RuntimeRefErrors.raise_NULL_EXEC_CTX();
6	int __sJT_1 = id;
7	String __sJT_2 = name;
8	short __sJT_3 = age;
9	String __sJT_4 = address;
10	synchronized (__sJT_execCtx) {
11	sqlj.runtime.profile.RTStatement __sJT_stmt = __sJT_execCtx.registerStatement
12                     (__sJT_connCtx, TestTableInserter_SJProfileKeys.getKey(0), 0);
13	try
14	{
15	__sJT_stmt.setInt(1, __sJT_1);
16	__sJT_stmt.setString(2, __sJT_2);
17	__sJT_stmt.setShort(3, __sJT_3);
18	__sJT_stmt.setString(4, __sJT_4);
19	__sJT_execCtx.executeUpdate();
20	}
21	finally
22	{
23	__sJT_execCtx.releaseStatement();
24	}
25	}
26	}

                
/*@lineinfo:filename=TestTableInserter*//*@lineinfo:user-code*//*@lineinfo:1^1*/// TestTableInserter.sqlj
import java.sql.*;

/**
 * Implements the method to insert a row into testtable
 */
public class TestTableInserter {

  /**
   * Stores the DefaultContext object used in the insert statement
   */
  protected sqlj.runtime.ref.DefaultContext _defaultContext;

  /**
   * Stores the DefaultContext object used in the insert statement
   */
  protected sqlj.runtime.ExecutionContext _executionContext ;

  /**
   * Sole Constructor. Sets the protected DefaultContext variable and initializes the
   * ExecutionContext to be used for the insert statement.
   * @param connCtx DefaultContext object used for SQLJ operations
   */
  public TestTableInserter( sqlj.runtime.ref.DefaultContext connCtx) {
    _defaultContext = connCtx;
    // This instance of ExecutionContext will be used in the insert operation
    _executionContext = new sqlj.runtime.ExecutionContext( );
  }

  /**
   * Inserts a single row into the testtable.
   * @param row TestTableRow object containing data to be inserted
   * @throws SQLException when database error occurs
   */
  public void insertRow(TestTableRow row) throws SQLException {
    int    id      = row.id;
    String name    = row.name;
    short  age     = row.age;
    String address = row.address;
    /*@lineinfo:generated-code*//*@lineinfo:40^4*/

//  ************************************************************
//  #sql [_defaultContext,_executionContext] { insert into testtable values (:id, :name, :age , :address)  };
//  ************************************************************

{
  sqlj.runtime.ConnectionContext __sJT_connCtx = _defaultContext;
  if (__sJT_connCtx == null) sqlj.runtime.error.RuntimeRefErrors.raise_NULL_CONN_CTX();
  sqlj.runtime.ExecutionContext __sJT_execCtx = _executionContext;
  if (__sJT_execCtx == null) sqlj.runtime.error.RuntimeRefErrors.raise_NULL_EXEC_CTX();
  int __sJT_1 = id;
  String __sJT_2 = name;
  short __sJT_3 = age;
  String __sJT_4 = address;
  synchronized (__sJT_execCtx) {
    sqlj.runtime.profile.RTStatement __sJT_stmt = __sJT_execCtx.registerStatement
	(__sJT_connCtx, TestTableInserter_SJProfileKeys.getKey(0), 0);
    try
    {
      __sJT_stmt.setInt(1, __sJT_1);
      __sJT_stmt.setString(2, __sJT_2);
      __sJT_stmt.setShort(3, __sJT_3);
      __sJT_stmt.setString(4, __sJT_4);
      __sJT_execCtx.executeUpdate();
    }
    finally
    {
      __sJT_execCtx.releaseStatement();
    }
  }
}


//  ************************************************************

/*@lineinfo:user-code*//*@lineinfo:40^106*/
  }
}/*@lineinfo:generated-code*/class TestTableInserter_SJProfileKeys
{
  private static TestTableInserter_SJProfileKeys inst = null;
  public static java.lang.Object getKey(int keyNum)
    throws java.sql.SQLException
  {
    if (inst == null)
    {
      inst = new TestTableInserter_SJProfileKeys();
    }
    return inst.keys[keyNum];
  }
  private final sqlj.runtime.profile.Loader loader = sqlj.runtime.RuntimeContext.getRuntime().getLoaderForClass(getClass());
  private java.lang.Object[] keys;
  private TestTableInserter_SJProfileKeys()
    throws java.sql.SQLException
  {
    keys = new java.lang.Object[1];
    keys[0] = sqlj.runtime.ref.DefaultContext.getProfileKey(loader, "TestTableInserter_SJProfile0");
  }
}

                
/*@lineinfo:filename=SQLJStmtCachedTestTableInserter*//*@lineinfo:user-code*//*@lineinfo:1^1*/// TestTableInserter.sqlj
import java.sql.*;

/**
 * Implements the method to insert a row into testtable
 */
public class SQLJStmtCachedTestTableInserter {

  /**
   * Stores the DefaultContext object used in the insert statement
   */
  protected sqlj.runtime.ref.DefaultContext _defaultContext;

  /**
   * Stores the DefaultContext object used in the insert statement
   */
  protected sqlj.runtime.ExecutionContext _executionContext ;

  /**
   * Stores the registered insert statement
   */
  protected sqlj.runtime.profile.RTStatement _insertStatement ;

  /**
   * Releases the RTStatement object during garbage collection
   * @throws SQLException if releaseStatement call fails
   */
  protected void finalize() throws SQLException {
    _executionContext.releaseStatement();
  }

  /**
   * Sole Constructor. Sets the protected DefaultContext variable and initializes the
   * ExecutionContext to be used for the insert statement.
   * @param connCtx DefaultContext object used for SQLJ operations
   * @throws SQLException if registerStatement call fails
   */
  public SQLJStmtCachedTestTableInserter( sqlj.runtime.ref.DefaultContext connCtx) throws SQLException {
    _defaultContext = connCtx;
    // This instance of ExecutionContext will be used in the insert operation
    _executionContext = new sqlj.runtime.ExecutionContext( );
    _insertStatement = _executionContext.registerStatement(_defaultContext, TestTableInserter_SJProfileKeys.getKey(0), 0);
  }

  /**
   * Inserts a single row into the testtable.
   * @param row TestTableRow object containing data to be inserted
   * @throws SQLException when database error occurs
   */
  public void insertRow(TestTableRow row) throws SQLException {
    int    id      = row.id;
    String name    = row.name;
    short  age     = row.age;
    String address = row.address;
    /*@lineinfo:generated-code*//*@lineinfo:40^4*/

//  ************************************************************
//  #sql [_defaultContext,_executionContext] { insert into testtable values (:id, :name, :age , :address)  };
//  ************************************************************

{
  sqlj.runtime.ConnectionContext __sJT_connCtx = _defaultContext;
  if (__sJT_connCtx == null) sqlj.runtime.error.RuntimeRefErrors.raise_NULL_CONN_CTX();
  sqlj.runtime.ExecutionContext __sJT_execCtx = _executionContext;
  if (__sJT_execCtx == null) sqlj.runtime.error.RuntimeRefErrors.raise_NULL_EXEC_CTX();
  int __sJT_1 = id;
  String __sJT_2 = name;
  short __sJT_3 = age;
  String __sJT_4 = address;
  synchronized (__sJT_execCtx) {
      _insertStatement.setInt(1, __sJT_1);
      _insertStatement.setString(2, __sJT_2);
      _insertStatement.setShort(3, __sJT_3);
      _insertStatement.setString(4, __sJT_4);
      __sJT_execCtx.executeUpdate();
  }
}


//  ************************************************************

/*@lineinfo:user-code*//*@lineinfo:40^106*/
  }
}/*@lineinfo:generated-code*/class TestTableInserter_SJProfileKeys
{
  private static TestTableInserter_SJProfileKeys inst = null;
  public static java.lang.Object getKey(int keyNum)
    throws java.sql.SQLException
  {
    if (inst == null)
    {
      inst = new TestTableInserter_SJProfileKeys();
    }
    return inst.keys[keyNum];
  }
  private final sqlj.runtime.profile.Loader loader = sqlj.runtime.RuntimeContext.getRuntime().getLoaderForClass(getClass());
  private java.lang.Object[] keys;
  private TestTableInserter_SJProfileKeys()
    throws java.sql.SQLException
  {
    keys = new java.lang.Object[1];
    keys[0] = sqlj.runtime.ref.DefaultContext.getProfileKey(loader, "TestTableInserter_SJProfile0");
  }
}

                
import java.sql.*;
import java.util.*;

class JDBCTableInserterTester
{

	static
	{
		try
		{
			Class.forName("COM.ibm.db2.jdbc.app.DB2Driver").newInstance();
		}
		catch (Exception e)
		{
			e.printStackTrace();
		}
	}

	public static void main(String args[]) throws Exception
	{
		String url = "jdbc:db2:testdb";
		Properties prop = new Properties();
		prop.put("user", "user");
		prop.put("password", "pwd");
		Connection con = null;
		int commitFrequency ;
		if (args.length ==0 )
			commitFrequency = 10000;
		else
			commitFrequency = Integer.parseInt(args[0]);
		try
		{
			// connect with user id/password
			con = DriverManager.getConnection(url, prop);
			con.setAutoCommit(false);
		}
		catch (SQLException e)
		{
			System.out.println("Error: could not open connection to database");
			System.err.println(e) ;
			System.exit(1);
		}

		System.out.println("Starting to insert : " + new java.util.Date() ) ;
		PreparedStatement inserter = con.prepareStatement("insert into testtable values(?,?,?,?)");;
		String name = "myname";
		short age = 27;
		char[] arr = new char[74];
		Arrays.fill(arr, 'a');
		String address = new String(arr);
		for ( int id = 0; id < 10000; id++ ) {
			inserter.setInt(1, id);
			inserter.setString(2,name);
			inserter.setShort(3,age);
			inserter.setString(4, address);
			inserter.executeUpdate();
			if ((id + 1) % commitFrequency == 0) con.commit();
		}
		con.commit();
		System.out.println("Finished inserting : " + new java.util.Date() ) ;
	}

}

                
import java.sql.*;
import java.util.*;
import sqlj.runtime.*;
import sqlj.runtime.ref.*;

class SQLJTableInserterTester
{

	static
	{
		try
		{
			Class.forName("COM.ibm.db2.jdbc.app.DB2Driver").newInstance();
		}
		catch (Exception e)
		{
			e.printStackTrace();
		}
	}

	public static void main(String args[]) throws Exception
	{
		String url = "jdbc:db2:testdb";
		Properties prop = new Properties();
		prop.put("user", "user");
		prop.put("password", "pwd");
		int commitFrequency ;
		if (args.length ==0 )
			commitFrequency = 10000;
		else
			commitFrequency = Integer.parseInt(args[0]);

		Connection con = null;
		DefaultContext ctx = null;
		try
		{
			// connect with default id/password
			con = DriverManager.getConnection(url, prop);
			con.setAutoCommit(false);
			ctx = new DefaultContext(con);
		}
		catch (SQLException e)
		{
			System.out.println("Error: could not get a default context");
			System.err.println(e) ;
			System.exit(1);
		}

		System.out.println("Starting to insert : " + new java.util.Date() ) ;
		TestTableRow row = new TestTableRow();
		TestTableInserter inserter = new TestTableInserter(ctx);
		row.name = "myname";
		row.age = 27;
		char[] arr = new char[74];
		Arrays.fill(arr, 'a');
		row.address = new String(arr);
		for ( int id = 0; id < 10000; id++ ) {
			row.id = id;
			inserter.insertRow(row);
			if ( (id + 1) % commitFrequency == 0 ) con.commit();
		}
		con.commit();
		System.out.println("Finished inserting : " + new java.util.Date() ) ;
	}

}