datagetterfromdb.java

EOmodeler 读取数据库的方法

package test.eof;



import java.util.List;

import com.webobjects.eoaccess.EODatabaseContext;
import com.webobjects.eoaccess.EOModel;
import com.webobjects.eoaccess.EOModelGroup;
import com.webobjects.eoaccess.EOUtilities;
import com.webobjects.eocontrol.EOEditingContext;
import com.webobjects.eocontrol.EOObjectStoreCoordinator;
import com.webobjects.foundation.NSArray;
import com.webobjects.foundation.NSMutableDictionary;

/**
 * @author Huang Ke
 * @version $Id: DataGetterFromDB.java,v 1.1 2007/12/14 11:36:59 lzh Exp $
 */

public class DataGetterFromDB {
	String EOMODEL_Name = "EOModel.eomodeld";
	String USER_NAME = "root";
	String PASSWORD = "123";
	String sql;
	EOModel model;
	EOObjectStoreCoordinator osc;
	EOModelGroup mp;
	EOEditingContext ec;
	NSMutableDictionary overrides;
	
	
	public DataGetterFromDB(){
		model = new EOModel(EOMODEL_Name);
		overrides = new NSMutableDictionary();
		overrides.takeValueForKey(USER_NAME, "username");
		overrides.takeValueForKey(PASSWORD, "password");
		
		osc = new EOObjectStoreCoordinator();
		mp = new EOModelGroup();
		mp.addModel(model);
		EOModelGroup.setModelGroupForObjectStoreCoordinator(osc, mp);
		
		ec = new EOEditingContext(osc);
		EODatabaseContext.forceConnectionWithModel(model, overrides, ec);
	}
	

	//return a NSArray which represents one task of the airplane 
	public NSMutableDictionary getAirplaneTaskByPointer(String AirplaneID,int count) {
		NSArray taskSet = new NSArray();
		NSMutableDictionary result;
		try {
			sql ="select * from flight where TAIL_NUM="+AirplaneID+" order by DEP_TIME";
			taskSet = EOUtilities.rawRowsForSQL(ec, model.name(),sql, null);
		} catch (Exception e) {
			System.out.println(e);
		}
		result = (NSMutableDictionary)taskSet.objectAtIndex(count);
		return result;
	}
	
	public NSArray getAirplanes() {
		NSArray taskSet = new NSArray();
		NSMutableDictionary result;
		try {
			sql ="select * from airplane";
			taskSet = EOUtilities.rawRowsForSQL(ec, model.name(),sql, null);
		} catch (Exception e) {
			System.out.println(e);
		}
		return taskSet;
	}
	
	public int airplanesNum() {
		NSArray taskSet = new NSArray();
		try {
			sql ="select * from airplane order by id";
			taskSet = EOUtilities.rawRowsForSQL(ec, model.name(),sql, null);
		} catch (Exception e) {
			System.out.println(e);
		}
		return taskSet.count();
	}
	
	public String airplaneID(int pointer) {
		NSArray taskSet = new NSArray();
		try {
			sql ="select * from airplane order by id";
			taskSet = EOUtilities.rawRowsForSQL(ec, model.name(),sql, null);
		} catch (Exception e) {
			System.out.println(e);
		}
		NSMutableDictionary result=(NSMutableDictionary)taskSet.objectAtIndex(pointer);
		return result.valueForKey("ID").toString();
	}

}