在 Symbian 平台上开发 DB2 Everplace Java 应用程序

CREATE TABLE STBL(
		  "IDX" INTEGER NOT NULL , 
		  "STRDESC" VARCHAR(10) NOT NULL)
   

syncdriver=com.ibm.mobileservices.isync.db2e.jni.DB2eISyncProvider
syncprotocol=isync:db2e:
server.url=http://9.181.135.112:8080
target.db.driver=com.ibm.db2e.jdbc.DB2eDriver
target.db.url=jdbc:db2e:
isync.user=syncUser
isync.password=syncPass
isync.timeout=60
isync.trace=default
# directory for configuration information
path=data
# directory for data
jdbcsuburl=.
# e.g. filesubdir
filesubdir=.
   

private void readProperties(String propFile)
{
	try
	{
	configProps =(PropertyResourceBundle)ResourceBundle.getBundle(propFile);
	userProps.put("syncdriver",configProps.getString("syncdriver"));
	userProps.put("syncprotocol", configProps.getString("syncprotocol"));
	userProps.put("server.url", configProps.getString("server.url"));
	userProps.put("target.db.driver",configProps.getString("target.db.driver"));
	userProps.put("target.db.url",configProps.getString("target.db.url");
	userProps.put("isync.user", configProps.getString("isync.user"));
	userProps.put("isync.password",configProps.getString("isync.password"));
	userProps.put("isync.timeout",configProps.getString("isync.timeout"));
	userProps.put("isync.trace", 	configProps.getString("isync.trace"));
	userProps.put("path", configProps.getString("path"));
	userProps.put("jdbcsuburl", configProps.getString("jdbcsuburl"));
	userProps.put("filesubdir",configProps.getString("filesubdir"));
	}
	catch (MissingResourceException mre)
	{throw mre;}
} //readProperties
   

package syncapp;
import java.sql.*;
/*
Import the ISync Java Client Package
*/
import com.ibm.mobileservices.isync.*; 
import com.ibm.mobileservices.isync.event.*; 
public class SyncListener implements ISyncListener {
/*
	Implement the eventIssued() method in the ISyncListener
	interface if you are interested in event notification (optional)
*/
public int eventIssued(ISyncEvent evt) 
{
	int evtType = evt.getEventType();//获得事件类型
	int evtCode = evt.getEventCode();//获得事件代码
	switch(evtType) 
	{
		// 针对事件类型进行相应处理
		case ISync.EVTTYPE_INFO: 
		case ISync.EVTTYPE_ERROR:
			...
			return ISync.RTNCB_DONE;

		case ISync.EVTTYPE_RETRY:
			...
		case ISync.EVTTYPE_CONFLICT:
		...
	}//end switch
	
}// end eventIssued
}// end class SyncListener

    

package syncapp;
import java.sql.*;
import java.util.*;
import com.ibm.db2e.jdbc.*;
/*
	Import the ISync Java Client Package
*/
import com.ibm.mobileservices.isync.*; 
public class SyncMain {
  // Synchronization 对象
 private ISyncProvider provider;
  private ISyncService service;
  private ISyncConfigStore config;
  private ISyncDriver syncer;	
  // Synchronization 参数
 private static PropertyResourceBundle configProps;
  private Properties userProps = new Properties();
  private ISyncSubscriptionSet ssArr[] = null;
  private void readProperties(String propFile)
{
		...		
} //readProperties	
public void runSample(String propFile)
{
  // 读属性文件配置
 readProperties(propFile);			
  // 加载sync driver
  Class.forName(userProps.getProperty("syncdriver"));
  // 获得synchronization service的实例
 provider = ISyncManager.getISyncProvider(userProps.getProperty("syncprotocol"));
  service = provider.createSyncService(userProps.getProperty("server.url"), userProps);
  // 获得configuration store的实例
 config = service.getConfigStore(userProps.getProperty("path"));
  // 获得 sync driver 的实例
 syncer = config.getSyncDriver(); 
  // 注册事件监听器的
 syncer.setSyncListener(new SyncListener());
  // 启动同步
 rc = syncer.sync();
...
} //runSample	
public static void main (String[] args) 
{ 
if (args.length == 1) 
{
	SyncMain sample = new SyncMain();			
	sample.runSample(args[0]);			
}
else 
	System.out.println("Usage: java ISyncSample property_file");
}

	}
    

package syncapp;
import java.sql.*;
import com.ibm.db2e.jdbc.DB2eDataSource;
public class JdbcMain {
	public void runSQL()
	{
	String url = "jdbc:db2e:c:/data/";   //移动数据库的位置在 c:/data/
        try {
            Connection con = null;           
            DB2eDataSource ds = new DB2eDataSource();
            ds.setUrl(url);
            con = ds.getConnection();        //建立移动数据库连接
              Statement st = con.createStatement();  //创建statement句柄 
              st.executeUpdate("INSERT INTO stbl VALUES (1,'John')"); //执行插入语句     
              ResultSet rs = st.executeQuery("SELECT * FROM stbl");//执行查询语句
              System.out.println("*** Query results:");
            while (rs.next()) {            //遍历结果集取得所有的行和列
                System.out.print("idx=" + rs.getString(1) + ", ");
                System.out.println("strdesc=" + rs.getString(2));
            }//end while          
            rs.close();
            st.close();
            con.close();          //断开数据库连接
        } catch (Exception ex) {
        	System.out.println(ex.toString());          
        }
	}// end runSQL
	public static void main (String[] args) 
	{
	JdbcMain jmain = new JdbcMain();
	jmain.runSQL();
	}
}

javac -target 1.1 -source 1.2 -classpath “isync4j.jar”  SyncListener.java
javac -target 1.1 -source 1.2 -classpath “./;isync4j.jar” SyncMain.java
javac -target 1.1 -source 1.2 -classpath “jdbc.jar;db2ejdbc.jar”  JdbcMain.java

SyncListener.class
SyncMain.class
JdbcMain.class
db2sync_db2e.properties
runSQL.j9 and runSync.j9
isync4j.dll for the Symbian 7s  
DB2EJDBC.dll for the Symbian 7s

-noverify -Dcom.ibm.oti.vm.bootstrap.library.path=C:\MyApp 
    -Xbootclasspath/a:c:\System\java\ext\db2ejdbc.jar;
    c:\System\java\ext\jdbc.jar;c:\System\java\ext\isync4j.jar;
    c:\MyApp -Xmx16m -verbose:sizes SyncMain db2sync_db2e

-noverify -Dcom.ibm.oti.vm.bootstrap.library.path=C:\MyApp 
    -Xbootclasspath/a:c:\System\java\ext\db2ejdbc.jar;
    c:\System\java\ext\jdbc.jar;c:\System\java\ext\isync4j.jar;
    c:\MyApp -Xmx16m -verbose:sizes JdbcMain