personspeed.java

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

package cn.speed.chapter1;

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 PersonSpeed {

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

	/**
	 * 
	 */
	public void save(Person person, PersonInfo personInfo) {
		Engine engine = null;
		logger.info("一对一保存开始..............");
		try {
			engine = EngineFactory.getEngine("link_mysql");
			Person p = (Person) engine.save(person);
			int id = p.getId();
			logger.info("得到Person的ID为：" + id);
			personInfo.setId(id);
			engine.save(personInfo);
			engine.commit();
		} catch (Exception e) {
			engine.rollback();
		} finally {
			engine.closeEngine();
		}
		logger.info("一对一保存结束..............");

	}

	
	@SuppressWarnings("unchecked")
	public void read(int personId) {
		Engine engine = null;
		logger.info("一对一读取开始..............");
		try {
			engine = EngineFactory.getEngine("link_mysql");
			String sql = "select p.id id, p.name name , pi.firstname firstname, pi.lastname lastname from person p,  personinfo pi where p.id=pi.id and p.id=? ";
			List<PersonView> list = engine.getQuery().getResults(sql,
					new Object[] { personId }, PersonView.class);

			for (PersonView view : list) {
				System.out.println("ID号为：" + view.getId());
				System.out.println("用户名为：" + view.getName());
				System.out.println("姓名为：" + view.getLastname()
						+ view.getFirstname());
			}
			//engine.commit();
		} catch (Exception e) {
			logger.error(e);
			//engine.rollback();
		} finally {
			engine.closeEngine();
		}

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

	}

	/**
	 * ��