dbupdateaction.java

eclipse+struts+sqlserver 简单图书管理系统,内有文档

/*
 * Generated by MyEclipse Struts
 * Template path: templates/java/JavaClass.vtl
 */
package kignbi.dong.action;

import java.sql.ResultSet;
import java.util.ArrayList;

import javax.servlet.ServletContext;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.sql.DataSource;

import kignbi.dong.Books;
import kignbi.dong.Users;
import kignbi.dong.Borrow;

import kignbi.dong.Constants;
import kignbi.dong.DB;

import org.apache.struts.action.Action;
import org.apache.struts.action.ActionForm;
import org.apache.struts.action.ActionForward;
import org.apache.struts.action.ActionMapping;
import org.apache.struts.action.ActionMessage;
import org.apache.struts.action.ActionMessages;

/** 
 * MyEclipse Struts
 * Creation date: 01-30-2008
 * 
 * XDoclet definition:
 * @struts.action
 * @struts.action-forward name="deluser" path="/admin/userlist.jsp"
 * @struts.action-forward name="upbooks" path="/admin/upbooks.jsp"
 * @struts.action-forward name="upusers" path="/admin/upusers.jsp"
 * @struts.action-forward name="upborrow" path="/admin/upborrows.jsp"
 * @struts.action-forward name="delbooks" path="/user/booklist.jsp"
 */
public class DbUpdateAction extends Action {
	/*
	 * Generated Methods
	 */

	/** 
	 * Method execute
	 * @param mapping
	 * @param form
	 * @param request
	 * @param response
	 * @return ActionForward
	 */
	public ActionForward execute(ActionMapping mapping, ActionForm form,
			HttpServletRequest request, HttpServletResponse response) {
		
		// TODO Auto-generated method stub
		String functiontype = request.getParameter("functiontype");
        System.out.print("functiontype:="+functiontype);
		ServletContext context = servlet.getServletContext();
		DataSource dataSource = (DataSource) context
				.getAttribute(Constants.DATASOURCE_KEY);
		DB db = new DB(dataSource);
		ActionMessages errors = new ActionMessages();
		String pageForward="ToUserLogin" ;
		if (functiontype.equals("upbooks")) {
			String bid=request.getParameter("bid");
			String sql="select * from books  where dbo.trim(bid)='"+bid+"'";
			try{ ResultSet rs=db.OpenSql(sql);
		    	 ArrayList upbook=new ArrayList();
		    	
		    	if(rs.next()){
		    		Books book=new Books();
		    		book.setBid(rs.getString(2));
		    		book.setBname(rs.getString(3));
		    		book.setBkind(rs.getString(4));
		    		book.setBpublish(rs.getString(5));
		    		book.setBauthor(rs.getString(6));
		    		book.setBprice(rs.getFloat(7));
		    		book.setBnumber(rs.getInt(8));
		    		book.setBdt_publish(rs.getString(9));
		    		upbook.add(book);
		    	    //request.setAttribute("count", count);
		            request.setAttribute("books",upbook);
		            pageForward="upbooks";
		      }
		      else {
				  errors.add(ActionMessages.GLOBAL_MESSAGE, new ActionMessage("update.book.search.failture"));
		         if (!errors.isEmpty()) {
			       saveErrors(request, errors);
			     }
		     }
			} 
			catch(Exception e){
				e.printStackTrace();
			}
		}
		if(functiontype.equals("delbook")){
			String bid1=request.getParameter("bid");
			String sql1="delete from books  where dbo.trim(bid)='"+bid1+"'";
			System.out.print("sql:"+sql1);
			try{ int state=db.ExecSql(sql1);
			   if (state==1){
				   errors.add(ActionMessages.GLOBAL_MESSAGE, new ActionMessage("delte.book.success"));
				   saveErrors(request, errors);
				   pageForward="delbook";
			   }
			   else{
				     errors.add(ActionMessages.GLOBAL_MESSAGE, new ActionMessage("delte.book.failture"));
			         if (!errors.isEmpty()) {
				       saveErrors(request, errors);
				       pageForward="delbook";
			         }
			   }
			}
			catch(Exception e){
				e.printStackTrace();
			}
		    	
		}
		if (functiontype.equals("upusers")) {
			String uid=request.getParameter("uid");
			String usql="select * from users  where dbo.trim(uid)='"+uid+"'";
			try{ ResultSet rs=db.OpenSql(usql);
		    	 ArrayList upuser=new ArrayList();
		    	 Users user=new Users();
		    	 System.out.print("upuser:"+usql+"");
		    	 if (rs.next()) {
		    			user.setUid(rs.getString("uid"));
		    			user.setUpassword(rs.getString("upassword"));
		    			user.setUsex(rs.getString("usex"));
		    			user.setUname(rs.getString("uname"));
		    			user.setUgrade(rs.getString("ugrade"));
		    			user.setUclass(rs.getString("uclass"));
		    		    upuser.add(user);
		    	        //request.setAttribute("count", count);
		                request.setAttribute("users",upuser);
		                pageForward="upusers";
		    	 }
		        
		         else {
				     errors.add(ActionMessages.GLOBAL_MESSAGE, new ActionMessage("update.user.search.failture"));
		             if (!errors.isEmpty()) {
			             saveErrors(request, errors);
			         }
		             pageForward="upusers";
		         }
			} 
			catch(Exception e){
				e.printStackTrace();
			}
		}
		if(functiontype.equals("deluser")){
			String uid1=request.getParameter("uid");
			String usql1="delete from users  where dbo.trim(uid)='"+uid1+"'";
			try{ int state=db.ExecSql(usql1);
			   if (state==1){
				   pageForward="deluser";
			   }
			   else{
				     errors.add(ActionMessages.GLOBAL_MESSAGE, new ActionMessage("delte.user.failture"));
			         if (!errors.isEmpty()) {
				       saveErrors(request, errors);
				       
			         }
			         pageForward="deluser";
			   } //else 
			}
			catch(Exception e){
				e.printStackTrace();
			}//catch
		    	
		}	
			
		if (functiontype.equals("upborrows")) {
			String id=request.getParameter("id");
			String usql="select * from borrow  where id='"+id+"'";
			try{ ResultSet rss=db.OpenSql(usql);
		    	 ArrayList upborrow=new ArrayList();
		    	 Borrow borrow=new Borrow();
		    	 if (rss.next()) {
		    		 borrow.setId(rss.getString("id"));
		 			borrow.setUid(rss.getString("uid"));
		 			borrow.setBid(rss.getString("bid"));
		 		    borrow.setDt_borrow(rss.getString("dt_borrow"));
		 			borrow.setDt_return(rss.getString("dt_return"));
		             borrow.setNumber(rss.getInt("number"));
		             borrow.setNot_num(rss.getInt("not_num"));
		             borrow.setDays(rss.getInt("days"));
		             borrow.setState(rss.getInt("state"));
		             borrow.setRemark(rss.getString("remark"));
		             request.setAttribute("borrows",upborrow);
		             upborrow.add(borrow);
		             pageForward="upborrows";
		             
		    	 }
		        
		         else {
				     errors.add(ActionMessages.GLOBAL_MESSAGE, new ActionMessage("update.borrow.search.failture"));
		             if (!errors.isEmpty()) {
			             saveErrors(request, errors);
			         }
		             pageForward="upborrows";
		         }
			} //try
			catch(Exception e){
				e.printStackTrace();
			}
		}//if		
		
		
	   
		db.close();
		return mapping.findForward(pageForward);
   }
}