recorddb.java

J2ME手机版游戏——配对赛源代码

/**
*记录型数据库类
*@CopyRight:Move2008
*@Author:bedlang
*@Version 1.0 2003/7/22
*/

package move.util;

import java.io.*;
import javax.microedition.io.*;
import javax.microedition.rms.*;
import move.util.Tool;

public class RecordDB {

    RecordStore myRecordStore;
    RecordEnumeration myEnumeration;
    String storeName;

    
    public RecordDB()
    {
    }

	/*
	*删除一个库
	*/
	public static void deleteStore(String StoreName)
	{
	   	try {
			RecordStore.deleteRecordStore(StoreName);
    	} catch (Exception e) {
    		System.out.println(StoreName + " - " + e.getMessage());
		}
	}    

    /**
     * 创建(打开)数据库
     */
    public void open(String StoreName) {
	    storeName = StoreName;
    	try {
    	    myRecordStore = RecordStore.openRecordStore(storeName, true);
    	} catch (RecordStoreException rse) {
			System.out.println("open "+storeName+" error:"+rse.getMessage());    	
		}
    }
    
    /**
     * 关闭数据库
     */
    public void close() {
    	try {
    	    myRecordStore.closeRecordStore();
    	} catch (RecordStoreNotOpenException rsnoe) {
		} catch (RecordStoreException rse) {
			System.out.println("close "+storeName+" error:"+rse.getMessage());
		}
    }
    
    /**
     * 求得数据库的记录数
     */
    public int getNumRecord() {
    	int j = 0;
    	try {
    	    j = myRecordStore.getNumRecords();
    	} catch (RecordStoreNotOpenException rsnoe) {
			System.out.println("getNumRecord error:"+rsnoe.getMessage());    	
    	}
		return j;
    }
    
    /*
     *add(向指定库中增加记录，返回新增加记录的记录序号)
     *
     *参数：record为要增加记录的内容
    */
    public int addRecord(String Record) {
    	int curRecord=0;
        ByteArrayOutputStream baos    = new ByteArrayOutputStream();
        DataOutputStream outputStream = new DataOutputStream(baos);
        try 
        {
            outputStream.writeUTF(Record);
            byte[] b = baos.toByteArray();
            curRecord = myRecordStore.addRecord(b, 0, b.length);
        }
        catch (Exception e) 
        {
        }
    	return curRecord;
    }

	/*
	*得到一条记录的内容
	*/
	public String getRecord(int RecordNum)
	{
		String record_str=null;
		try{
			byte[] b = myRecordStore.getRecord(RecordNum);
            ByteArrayInputStream bais = new ByteArrayInputStream(b);
            DataInputStream inputStream = new DataInputStream(bais);
            record_str = inputStream.readUTF();
		}catch(Exception e){
		}
		return record_str;
	} 

	/*
	*修改一条记录
	*/
	public void setRecord(int RecordId, String Record) 
	{
        ByteArrayOutputStream baos    = new ByteArrayOutputStream();
        DataOutputStream outputStream = new DataOutputStream(baos);
        try 
        {
            outputStream.writeUTF(Record);
            byte[] b = baos.toByteArray();
            myRecordStore.setRecord(RecordId, b, 0, b.length);
        }
        catch (Exception e) 
        {
        }
	}
	
	/*
	*删除一条记录
	*/
	public void deleteRecord(int RecordId)
	{
        try 
        {
            myRecordStore.deleteRecord(RecordId);
        }
        catch (Exception e) 
        {
        }	
	}
	
	// @see move.util.Tool.getField
	public String getField(String Str, int FieldNo, String SeparatorChar)
	{
		return Tool.getField(Str,FieldNo,SeparatorChar);
	}

}