gbs_msubrelation_db.java

对日软件外包 为东芝做的一个全球商业管理系统

/** 
 * method GBS_MMember_DB.java
 * created on 07-29-2004
 * 
 * @author   GXK
 * @version  1.0
 */

package DB;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;

import javax.sql.DataSource;

import COMMON.BaseCommonCheck;
import COMMON.MessageList;
import COMMON.ReturnValue;
import COMMON.SystemConstants;

public class GBS_MSubRelation_DB implements SystemConstants {

	private DataSource datasource = null;

	/**
	 * get datasource from logic
	 * @param datasource
	 */
	public GBS_MSubRelation_DB(DataSource datasource) {
		this.datasource = datasource;
	}

	/**
	 * get Subsidiarycode2 by Subsidiarycode1
	 * @param		String Subsidiarycode1
	 * @return		ArrayList
	 * @exception	Exception    Exception for information of other errors
	 * @since		2004/07/29
	 */

	public ReturnValue selectBySubsidiarycode1(String subsidiarycode1) throws Exception {
		//Add by Gxk 2004/09/10 Start
		subsidiarycode1 = BaseCommonCheck.convertSql(subsidiarycode1);
		//Add by Gxk 2004/09/10 End
		StringBuffer sql = new StringBuffer();
		ReturnValue returnValueD = new ReturnValue();
		MessageList errorMsg = new MessageList();
		returnValueD.setMessageList(errorMsg);

		/////////////////////////////////////////////////////////////////////////////
		//EDIT SQL
		sql.append("SELECT ");
		sql.append("  M_SUB_RELATION.SUBSIDIARY_CODE2 ");
		sql.append("FROM ");
		sql.append("  M_SUB_RELATION,M_SUBSIDIARY ");
		sql.append("WHERE M_SUB_RELATION.SUBSIDIARY_CODE2=M_SUBSIDIARY.SUBSIDIARY_CODE ");
		//if (!"".equals(subsidiarycode1)) {
		sql.append(" AND SUBSIDIARY_CODE1 = '" + subsidiarycode1 + "' ");
		//}
		sql.append(" ORDER BY M_SUBSIDIARY.DISP_ORDER");
		//END EDIT SQL		
		//DEFINE RETURNVALUE
		ArrayList subsidiarycode2List = new ArrayList();
		//END
		/////////////////////////////////////////////////////////////////////////////

		ResultSet rset = null;
		Connection conn = null;
		Statement st = null;

		try {
			conn = this.datasource.getConnection();
			st = conn.createStatement();
			rset = st.executeQuery(sql.toString());
			////////////////////////////////////////////////////////////////////////////
			//GET DATA FROM DB RESULTSET
			while (rset.next()) {
				subsidiarycode2List.add(rset.getString("SUBSIDIARY_CODE2"));
			}
			if (subsidiarycode2List.size() == 0) {
				//returnValueD.setErrorCode("10000008");
				errorMsg.setMessage("", "", "10000008", Integer.MIN_VALUE);
				returnValueD.setBussinessError();
			} else {
				//returnValueD.setErrorCode("");
				returnValueD.setDataValue(subsidiarycode2List);
			}
			//END GET DATA
			////////////////////////////////////////////////////////////////////////////
		} catch (Exception exception) {
			System.out.println("[Error Happen!]");
			System.out.println("[Start Trace]");
			exception.printStackTrace();
			System.out.println("[End Trace]");
			throw exception;
		} finally {
			//CLOSE DB CONN
			try {
				if (rset != null) {
					rset.close();
				}
				if (st != null) {
					st.close();
				}
				if (conn != null) {
					conn.close();
				}
			} catch (SQLException se) {
			}
		}

		return returnValueD;
	}

}