📄 gbs_mmember_db.java
字号:
return returnValue;
}
/**
* delete GBS_MMember_st by userid
* @param String userid
* @param String loginuserid
* @return ReturnValue
* @exception Exception Exception for information of other errors
* @since 2004/07/30
*/
public ReturnValue deleteByUserId(String userid, String loginUserId) throws Exception {
//Add by Gxk 2004/09/10 Start
userid = BaseCommonCheck.convertSql(userid);
loginUserId = BaseCommonCheck.convertSql(loginUserId);
//Add by Gxk 2004/09/10 End
StringBuffer sql1 = new StringBuffer();
StringBuffer sql2 = new StringBuffer();
ReturnValue returnValue = new ReturnValue();
MessageList messageList = new MessageList();
/////////////////////////////////////////////////////////////////////////////
//EDIT SQL
//edit sql1:select date from DB by userid
sql1.append(" SELECT ");
sql1.append(" USER_ID, ");
sql1.append(" DELETE_FLG ");
sql1.append(" FROM ");
sql1.append(" M_MEMBER ");
sql1.append(" WHERE USER_ID = '" + userid + "' ");
sql1.append(" FOR UPDATE");
//edit sql2:update date at DB by in_st
sql2.append(
"UPDATE M_MEMBER SET DELETE_FLG='D',UPDATE_USER='"
+ loginUserId
+ "',UPDATE_DATE=SYSDATE WHERE USER_ID = '"
+ userid
+ "' ");
//END EDIT SQL
//END
/////////////////////////////////////////////////////////////////////////////
ResultSet rset = null;
Connection conn = null;
Statement st = null;
try {
conn = this.datasource.getConnection();
st = conn.createStatement();
rset = st.executeQuery(sql1.toString());
////////////////////////////////////////////////////////////////////////////
//GET DATA FROM DB RESULTSET
boolean isError = true;
while (rset.next()) {
isError = false;
}
if (isError) {
messageList.setMessage("UserId", userid, "10000001", Integer.MIN_VALUE);
}
if (!isError) {
PreparedStatement pstmt = conn.prepareStatement(sql2.toString());
int countDelete = pstmt.executeUpdate();
if (countDelete > 0) {
conn.commit();
} else {
conn.rollback();
}
}
//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) {
}
if (messageList.size() > 0) {
returnValue.setMessageList(messageList);
returnValue.setBussinessError();
}
}
return returnValue;
}
/**
* insert GBS_MMember_st by userid
* @param GBS_MMember_stBean in_st
* @return ReturnValue
* @exception Exception Exception for information of other errors
* @since 2004/07/30
*/
public ReturnValue insertDB(GBS_MMember_stBean in_st) throws Exception {
StringBuffer sql1 = new StringBuffer();
StringBuffer sql2 = new StringBuffer();
ReturnValue returnValue = new ReturnValue();
MessageList messageList = new MessageList();
////////////////////////////////////////////////////////////////////////////
//EDIT SQL
//edit sql1:select date from DB by userid
sql1.append("SELECT ");
sql1.append(" USER_ID ");
sql1.append("FROM ");
sql1.append(" M_MEMBER ");
sql1.append("WHERE USER_ID = '" + BaseCommonCheck.convertSql(in_st.getUserId()) + "' ");
//edit sql2:update date at DB by in_st
sql2.append("INSERT INTO ");
sql2.append(" M_MEMBER ( ");
sql2.append(" USER_ID , "); //儐乕僓乕ID
sql2.append(" DISP_ORDER , "); //昞帵弴彉
sql2.append(" PASSWORD , "); //僷僗儚乕僪
sql2.append(" MEMBER_NAME_FIRST , "); //儊儞僶乕柤乮First)
sql2.append(" MEMBER_NAME_LAST , "); //儊儞僶乕柤(Last)
sql2.append(" SUBSIDIARY_CODE , "); //尰朄僐乕僪
sql2.append(" DEPT , "); //晹彁
sql2.append(" E_MAIL , "); //儊乕儖傾僪儗僗
sql2.append(" TELEPHONE , "); //揹榖斣崋
sql2.append(" BOSS_NAME_FIRST , "); //忋巌偺柤慜(First)
sql2.append(" BOSS_NAME_LAST , "); //忋巌偺柤慜(Last)
sql2.append(" BOSS_E_MAIL , "); //忋巌偺儊乕儖傾僪儗僗
sql2.append(" MEMBER_KIND , "); //儊儞僶乕庬椶
sql2.append(" ADMIN_AUTHORITY , "); //俙倓倣倝値尃尷
sql2.append(" DOWNLOAD_OK , "); //僟僂儞儘乕僪壜斲
sql2.append(" DELETE_FLG , "); //嶍彍僼儔僌
sql2.append(" CREATE_USER , "); //嶌惉儐乕僓乕
sql2.append(" VISIBLE , ");
sql2.append(" CREATE_DATE "); //嶌惉擔帪
sql2.append(" ) ");
sql2.append("VALUES ( ");
sql2.append("'" + BaseCommonCheck.convertSql(in_st.getUserId()) + "', ");
sql2.append("'" + BaseCommonCheck.convertSql(in_st.getDispOrder()) + "', ");
sql2.append("'" + BaseCommonCheck.convertSql(in_st.getPassword()) + "', ");
sql2.append("'" + BaseCommonCheck.convertSql(in_st.getMemberNameFirst()) + "', ");
sql2.append("'" + BaseCommonCheck.convertSql(in_st.getMemberNameLast()) + "', ");
sql2.append("'" + BaseCommonCheck.convertSql(in_st.getSubsidiaryCode()) + "', ");
sql2.append("'" + BaseCommonCheck.convertSql(in_st.getDept()) + "', ");
sql2.append("'" + BaseCommonCheck.convertSql(in_st.getEmail()) + "', ");
sql2.append("'" + BaseCommonCheck.convertSql(in_st.getTelephone()) + "', ");
sql2.append("'" + BaseCommonCheck.convertSql(in_st.getBossNameFirst()) + "', ");
sql2.append("'" + BaseCommonCheck.convertSql(in_st.getBossNameLast()) + "', ");
sql2.append("'" + BaseCommonCheck.convertSql(in_st.getBossEMail()) + "', ");
sql2.append("'" + BaseCommonCheck.convertSql(in_st.getMenberKind()) + "', ");
sql2.append("'" + BaseCommonCheck.convertSql(in_st.getAdminAuthority()) + "', ");
sql2.append("'" + BaseCommonCheck.convertSql(in_st.getDownloadOk()) + "', ");
sql2.append("'" + BaseCommonCheck.convertSql(in_st.getDeleteFlg()) + "', ");
sql2.append("'" + BaseCommonCheck.convertSql(in_st.getCreateUser()) + "', ");
sql2.append("'" + BaseCommonCheck.convertSql(in_st.getVisible()) + "', ");
sql2.append(" SYSDATE");
sql2.append(" ) ");
System.out.println(sql2.toString());
//END EDIT SQL
//END
/////////////////////////////////////////////////////////////////////////////
ResultSet rset = null;
Connection conn = null;
Statement st = null;
try {
conn = this.datasource.getConnection();
st = conn.createStatement();
rset = st.executeQuery(sql1.toString());
////////////////////////////////////////////////////////////////////////////
//GET DATA FROM DB RESULTSET
boolean isError = false;
while (rset.next()) {
if (in_st.getUserId().equals(rset.getString("USER_ID"))) {
isError = true;
}
if (isError) {
messageList.setMessage("UserId", in_st.getUserId(), "10000002", Integer.MIN_VALUE);
}
}
if (!isError) {
PreparedStatement pstmt = conn.prepareStatement(sql2.toString());
int countInsert = pstmt.executeUpdate();
if (countInsert > 0) {
conn.commit();
} else {
conn.rollback();
}
}
//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) {
}
if (messageList.size() > 0) {
returnValue.setMessageList(messageList);
returnValue.setBussinessError();
}
}
return returnValue;
}
/**
* get Memter List info by sql
* @return ReturnValue
* @throws Exception
*/
public ReturnValue getMemberList(String admins,String loginId) throws Exception {
HashMap retdat = new HashMap();
ReturnValue returnValueD = new ReturnValue();
MessageList messageList = new MessageList();
returnValueD.setMessageList(messageList);
//sqla========(start)==========
StringBuffer sqla = new StringBuffer();
sqla.append(" SELECT ");
sqla.append(" MEMBER_NAME_FIRST, ");
sqla.append(" MEMBER_NAME_LAST, ");
sqla.append(" DEPT, ");
sqla.append(" E_MAIL, ");
sqla.append(" TELEPHONE, ");
sqla.append(" MEMBER_KIND, ");
sqla.append(" DISP_ORDER, ");
sqla.append(" DELETE_FLG, ");
sqla.append(" VISIBLE, ");
sqla.append(" USER_ID ");
sqla.append(" FROM ");
sqla.append(" M_MEMBER ");
//sqla.append(" WHERE (DELETE_FLG<>'D' OR DELETE_FLG IS NULL) ");
sqla.append(" ORDER BY ");
sqla.append(" MEMBER_KIND, ");
sqla.append(" DISP_ORDER, ");
sqla.append(" USER_ID ");
//sqla========(end)======================
//sqlb===========(start)======================
StringBuffer sqlb = new StringBuffer();
sqlb.append(" SELECT ");
sqlb.append(" M_MEMBER.MEMBER_NAME_FIRST, ");
sqlb.append(" M_MEMBER.MEMBER_NAME_LAST, ");
sqlb.append(" M_MEMBER.DEPT, ");
sqlb.append(" M_MEMBER.E_MAIL, ");
sqlb.append(" M_MEMBER.TELEPHONE, ");
sqlb.append(" M_MEMBER.SUBSIDIARY_CODE, ");
sqlb.append(" M_MEMBER.BOSS_NAME_FIRST, ");
sqlb.append(" M_MEMBER.BOSS_NAME_LAST, ");
sqlb.append(" M_MEMBER.BOSS_E_MAIL, ");
sqlb.append(" M_MEMBER.DELETE_FLG, ");
sqlb.append(" M_MEMBER.VISIBLE, ");
sqlb.append(" M_MEMBER.USER_ID, ");
sqlb.append(" M_SUBSIDIARY.SUBSIDIARY_NAME, ");
sqlb.append(" M_SUBSIDIARY.DISP_ORDER ,");
sqlb.append(" M_SUBSIDIARY.SUBSIDIARY_CODE ");
sqlb.append(" FROM ");
sqlb.append(" M_MEMBER, ");
sqlb.append(" M_SUBSIDIARY ");
sqlb.append(" WHERE M_MEMBER.SUBSIDIARY_CODE = M_SUBSIDIARY.SUBSIDIARY_CODE");
sqlb.append(" ORDER BY ");
sqlb.append(" M_SUBSIDIARY.DISP_ORDER ,");
sqlb.append(" M_MEMBER.DISP_ORDER,M_MEMBER.USER_ID ");
//sqlb=============(end)========================
ResultSet rseta = null;
ResultSet rsetb = null;
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -