persononetomanyspeed.java

羽量级数据持久层开发框架

package cn.speed.chapter1;

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

import org.apache.log4j.Logger;
import org.speedframework.engine.Engine;
import org.speedframework.engine.EngineFactory;

/**
 * Class PersonSpeed
 * 
 * @author <a href="mailto:[e-mail]"> lizf </a>
 * @version $Revision:1.0.0, $Date: 2007-10-24 上午07:46:21 $
 */
public class PersonOneToManySpeed {

	private static Logger logger = Logger.getLogger(PersonOneToManySpeed.class);

	public void save(List<Person> persons, Department department) {
		Engine engine = null;
		logger.info("一对多保存开始..............");
		try {
			engine = EngineFactory.getEngine("link_mysql");
			for (Person person : persons) {
				int id = department.getId();
				logger.info("得到Department的ID为：" + id + "， 名称为："
						+ person.getName());
				person.setDepartmentid(id);
				engine.save(person);
			}

			engine.commit();
		} catch (Exception e) {
			engine.rollback();
		} finally {
			engine.closeEngine();
		}
		logger.info("一对多保存结束..............");

	}

	@SuppressWarnings("unchecked")
	public void read(int departmentId) {
		Engine engine = null;
		logger.info("一对多读取开始..............");
		try {
			engine = EngineFactory.getEngine("link_mysql");
			String sql = "select p.id id, p.name personName , d.name departmentName from person p,  "
					+ "department d where p.departmentId = d.id and d.id=? ";
			List<PersonDepartmentView> list = engine.getQuery().getResults(sql,
					new Object[] { departmentId }, PersonDepartmentView.class);

			for (PersonDepartmentView view : list) {
				System.out.println("用户ID号为：" + view.getId());
				System.out.println("用户名为：" + view.getPersonName());
				System.out.println("用户所在部门为：" + view.getDepartmentName());
			}
			// engine.commit();
		} catch (Exception e) {
			logger.error(e);
			// engine.rollback();
		} finally {
			engine.closeEngine();
		}

		logger.info("一对多读取结束..............");

	}

	/**
	 * ��