checkaction.java

来自「采用web2.0技术,采用动态标签,sql语句全部存储在数据库里面.开发速度快.」· Java 代码 · 共 110 行

package com.sztheater.biz.register;

import java.io.IOException;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import org.apache.struts.action.Action;
import org.apache.struts.action.ActionForm;
import org.apache.struts.action.ActionMapping;
import org.apache.struts.action.ActionForward;
import java.sql.*;
import com.sztheater.framework.web.*;
import com.sztheater.framework.util.*;
import java.util.*;
import javax.servlet.http.*;

public class CheckAction extends Action {
	
	  
	
		protected int checkInfo (String username,HttpServletRequest request) {
			
			String user = username;
			int iSuccFlag = 0;
			int iExistsNum =0;
			String strMsg = "";
			String strSQL = "";
			HttpSession _httpSession= null;
			ResultSet  rs  = null;
		    Statement  st  = null;
		    Connection conn      = null;
			ValueObject sendPack = new ValueObject();
			_httpSession = request.getSession();
			try{
			    
			    try{
				conn        = DbFunc.getConnection(false);
			    }catch(Exception e){
			    iSuccFlag = -90102;
				if(conn!=null) DbFunc.free(conn,iSuccFlag);
				conn = null;
				strMsg    = "服务取数据库连接异常"+e.getMessage();
				System.out.println("strMsg"+strMsg);
		       }
		 //取得执行数据库操作Statement
				st   = conn.createStatement();
				strSQL  = "select count(*) as num \n"
					+ "from T_NetCustomer \n"
					+ "where LoginName = '"+username+"'";
					System.out.println("strSQL*="+strSQL);
			     rs   = st.executeQuery( strSQL);
				if (rs!=null && rs.next()){
					iExistsNum = rs.getInt("num");
				}
				rs.close();
				rs = null;
				if(iExistsNum>0){
					iSuccFlag = -90010106;
					strMsg = "该用户已被占用";
					sendPack.setErrMsg(iSuccFlag,strMsg);
					_httpSession.removeAttribute("feedback");
					request.setAttribute("feedback","failure");
					System.out.println(strMsg);
				}else{
		    strMsg = "可以使用";
			iSuccFlag = 1;
			sendPack.setErrMsg(iSuccFlag,strMsg);
			request.setAttribute("feedback","ok");
			request.setAttribute("loginname",username);
			System.out.println(strMsg);
			}
				
			} catch(Exception e){
				
		    iSuccFlag = 20102005;
			strMsg = e.getMessage();
			if(sendPack!=null) sendPack.addTrace(strMsg);
			strMsg = "失败！";
	//		System.out.println(strMsg +"\n" + e.getMessage() + "\n" + strSQL);
		}finally{
			try{
				if(rs!=null) rs.close();
				if (conn!=null) conn.close();
			}catch(Exception e1){
			}
			try{
				if(st!=null) st.close();
			}catch(Exception e1){
			}
			
			rs= null;
			st= null;
			return 0;
		}	
			}
			
		public ActionForward execute(ActionMapping mapping,
						ActionForm form,
						HttpServletRequest request,
						HttpServletResponse response)
						throws IOException,ServletException {
				
				String target = new String("success");
				String username = ((CheckForm)form).getUsername();
				
				checkInfo(username,request);
				System.out.println(request.getAttribute("feedback"));
	             return (mapping.findForward(target));					
								}
	}