senddata.java

自行开发的j2me小软件

 /*
 * 创建日期 2005-2-8
 *
 * TODO 要更改此生成的文件的模板，请转至
 * 窗口 － 首选项 － Java － 代码样式 － 代码模板
 */
package src;

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.InputStream;
import java.io.OutputStream;

import javax.microedition.io.Connector;
import javax.microedition.io.StreamConnection;
import javax.microedition.lcdui.Alert;
import javax.microedition.lcdui.AlertType;
import javax.microedition.lcdui.Display;
import javax.microedition.rms.RecordEnumeration;
import javax.microedition.rms.RecordStore;

/**
 * @author ryu-java
 *
 * TODO 要更改此生成的类型注释的模板，请转至
 * 窗口 － 首选项 － Java － 代码样式 － 代码模板
 */
public class SendData extends Thread{
	
	Display display ;
	String DBname;
	RecordEnumeration re;
	RecordStore DataS;
	MoneyData vd;
	int count=0;

	public SendData(String DBname1,Display d)
	{
		
		display = d ;
		DBname=DBname1;
	}
	public SendData()
	{
		
		
	}
	public void run()
	{
		String url = "socket://127.0.0.1:8383";//"socket://wap.8800.or:8383";
		StreamConnection conn = null;
		InputStream is = null;
		OutputStream os = null ;
		DataInputStream dis = null ;
		DataOutputStream dos = null ;
		String line = "";
		try {
    			conn = (StreamConnection)Connector.open(url);
		

   			is = conn.openInputStream();	
   			os = conn.openOutputStream();  
   			dis = new DataInputStream(is) ;
   			dos = new DataOutputStream(os) ;
   			//送出查询字符串
   			
   			vd=new MoneyData();
   		   	vd.setDBname(DBname);
   			DataS=vd.openRS();
   			try
   			{
   			re=DataS.enumerateRecords(null,null,false);
   			count=re.numRecords();
   					
			
   			
   			}catch(Exception e)
   			{
   			}
   			
   			
   			
   			
   			
   			dos.writeInt(count);
   			for(int i=0;i<count;i++)
   			{
   				int id=re.nextRecordId();
   				byte tmp[]=DataS.getRecord(id);
   				vd.decode(tmp);
   					
   				
   			dos.writeInt(id);
   			dos.writeInt(vd.getDate());
   			dos.writeUTF(vd.getName());
   			dos.writeInt(vd.getSum());
   			}
   			dos.flush() ;
   			
   			//取得结果字符串
   			
			while(true)
			{
				line = line + dis.readUTF() ;
				System.out.println(line) ;	
			}
			
			
 		}catch (Exception ioe) 
 		{
 			Alert al = new Alert("连接错误",ioe.toString(),null,AlertType.CONFIRMATION);
 	 		al.setTimeout(Alert.FOREVER) ;
 	 		display.setCurrent(al) ;	
 		}
 		finally
 		{
 			try
 			{
 				if(conn!=null)
 					conn.close();
 			}catch(Exception e){}
 		}
 		Alert al = new Alert("成功传送",line,null,AlertType.CONFIRMATION);
 		al.setTimeout(Alert.FOREVER) ;
 		display.setCurrent(al) ;
	}

}