expelement.java

OBPM是一个开源

package cn.myapps.core.expimp.exp.ejb;

import java.util.Collection;
import java.util.Iterator;
import java.util.LinkedHashMap;
import java.util.Map;

import cn.myapps.base.dao.ValueObject;
import cn.myapps.core.expimp.exp.util.SQLPackage;

public abstract class ExpElement {
	public final static String FOREINGKEY_COLUMN_MODULE = "MODULE";

	public final static String FOREINGKEY_COLUMN_APPLICATION = "APPLICATION";

	protected String[] expids;

	private boolean expAll = false; // 导出全部

	private boolean expDatas = false; // 导出数据

	public abstract String getName();

	public ExpElement(boolean expAll) {
		setExpAll(expAll);
	}
	
	public abstract Map exportSQLS(String[] ids, Collection ignoreIds)
			throws Exception;

	protected Map exportSQLSDefaultImp(String[] ids, Collection ignoreIds)
			throws Exception {
		Map rtn = new LinkedHashMap();
		StringBuffer query = new StringBuffer();

		for (int i = 0; i < ids.length; i++) {
			if (ignoreIds.contains(ids[i]))
				continue;

			ignoreIds.add(ids[i]);

			query.append("SELECT * FROM ");
			query.append(getName() + " ");
			query.append("WHERE id ='");
			query.append(ids[i] + "'");
			SQLPackage values = new SQLPackage(getName(), query.toString());

			rtn.put(ids[i], values);
			query = new StringBuffer();
		}
		return rtn;
	}

	public String[] getIdsFromValueObjectColles(Collection colls) {
		String[] rtn = new String[0];

		int i = 0;
		if (colls != null) {
			rtn = new String[colls.size()];
			for (Iterator iter = colls.iterator(); iter.hasNext();) {
				ValueObject vo = (ValueObject) iter.next();
				rtn[i] = vo.getId();
				i++;
			}
		}

		return rtn;
	}

	public String[] getExpids() {
		return expids;
	}

	public void setExpids(String[] expids) {
		this.expids = expids;
	}

	public boolean isExpAll() {
		return expAll;
	}

	public void setExpAll(boolean expAll) {
		this.expAll = expAll;
	}

	public boolean isExpDatas() {
		return expDatas;
	}

	public void setExpDatas(boolean expDatas) {
		this.expDatas = expDatas;
	}

	
}