defaultengine.java

羽量级数据持久层开发框架

package org.speedframework.engine;

import org.speedframework.action.IDateBaseVersionAction;
import org.speedframework.application.DefaultSourceBuilder;
import org.speedframework.configuration.ConfigurationImpl;
import org.speedframework.entity.ParamEntity;
import org.speedframework.message.IMessage;
import org.speedframework.message.SynchronousDBTypeMessage;

public class DefaultEngine extends AbstractEngine {

	private DefaultEngine(String applicationID) {
		this.applicationFactory = new DefaultSourceBuilder();
		actionFactory = applicationFactory.getActionBuilderFactory();
		this.connectionAdaptor = ConfigurationImpl.newInstance()
				.getConnectionAdaptor(applicationID);
	}

	public static Engine getProxy(String applicationID) {
		Engine engine = null;
		DefaultEngine de = new DefaultEngine(applicationID);
		String dbtype = de.getDateBaseVersion(applicationID);

		if ("mysql".equals(dbtype)) {
			engine = new MySQLEngine(de.connectionAdaptor);
			engine.setApplicationID(applicationID);
		}

		if ("oracle".equals(dbtype)) {
			engine = new OracleEngine(de.connectionAdaptor);
			engine.setApplicationID(applicationID);
		}

		if ("hsql database engine".equals(dbtype)) {
			engine = new HSQLDBSQLEngine(de.connectionAdaptor);
			engine.setApplicationID(applicationID);
		}

		if ("access".equals(dbtype)) {
			engine = new AccessEngine(de.connectionAdaptor);
			engine.setApplicationID(applicationID);
		}

		if ("postgresql".equals(dbtype)) {
			engine = new PostgresqlEngine(de.connectionAdaptor);
			engine.setApplicationID(applicationID);
		}

		if ("microsoft sql server".equals(dbtype)) {
			engine = new MSSQLEngine(de.connectionAdaptor);
			engine.setApplicationID(applicationID);
		}
		
		if (dbtype.indexOf("db2") > -1) {
			engine = new DB2Engine(de.connectionAdaptor);
			engine.setApplicationID(applicationID);
		}

		return engine;
	}

	public String getDateBaseVersion(String applicationID) {
		this.setApplicationID(applicationID);

		IMessage message = new SynchronousDBTypeMessage();
		IDateBaseVersionAction action = actionFactory.getDateBaseAction();

		// IState state = null;
		message.setAction(action);
		message.setApplicationID(this.application.getApplicationID());

		ParamEntity entity = new ParamEntity();

		entity.setConnectionAdaptor(this.connectionAdaptor);
		message.setParamEntity(entity);
		application.dealMessage(message);

		String _dataBaseVersion = (String) message.getPojos();

		return _dataBaseVersion;
	}

	public Query getQuery() {
		return null;
	}
}