logondao.java

基于SPRING+DWR+EXT 技术的一个小项目（附源码和数据库脚本）

package com.hr.dao;

import java.util.ArrayList;
import java.util.List;

import com.hr.User;
import com.philisense.arc.base.ProxyWebArcContext;
import com.philisense.arc.base.jdbc.query.Query;
import com.philisense.arc.base.jdbc.query.Runner;

public class LogonDAO {

	private Query query;

	private Runner getRunner() throws Exception {
		return (Runner) ProxyWebArcContext.getProxyArcContext().getQueryFactory().getRunnerObject();
	}

	private Query getQuery() throws Exception {
		if (query == null) {
			query = (Query) ProxyWebArcContext.getProxyArcContext().getQueryFactory().getObject();
		}
		return query;
	}

	public int removeRecords(ArrayList<String> ids) throws Exception {

		if (ids == null || ids.size() == 0) {
			return -1;
		}

		String sql = "delete from user where id in (";
		for (int i = 0; i < ids.size(); i++) {
			sql += ids.get(i).toString() + ",";
		}
		sql = sql.substring(0, sql.length() - 1) + ")";

		Runner runner = getRunner();
		int count = runner.executeUpdate(sql);
		runner.close();

		return count;
	}

	public List<User> getRecords() throws Exception {

		Query query = getQuery();
		query.setNullWarp(true);
		query.setTrimWarp(true);
		query.setColumnWarp(false);
		query.setCodeWarp(false);

		return (List<User>) query.queryToBeanList("select * from user order by id", User.class);
	}

	public List getUserList(String userName, String passWord) throws Exception {

		Query query = getQuery();
		query.setNullWarp(true);
		query.setTrimWarp(true);
		query.setColumnWarp(false);
		query.setCodeWarp(false);

		List results = query.queryToBeanList("select * from user where userName='" + userName + "' and passWord='"
				+ passWord + "'", User.class);

		return results;
	}
	
	public int insertUser(String userName, String passWord, String isValid) throws Exception {
		String sql = "insert into user(userName,passWord,isValid) values('"+userName+"','"+passWord+"',"+isValid+")";
		
		Runner runner= getRunner();
		int count=runner.executeUpdate(sql);
		runner.close();
		
		return count;
	}

	public int updateUser(String id, String userName, String passWord, String isValid) throws Exception { 
		String sql = "update user set userName='"+userName+"',passWord='"+passWord+"',isValid="+isValid+" where id="+id;
		
		Runner runner= getRunner();
		int count=runner.executeUpdate(sql);
		runner.close();
		
		return count;
	}
}