connectionaction.java

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

package org.speedframework.action;

import org.speedframework.exception.SpeedFrameworkException;
import org.speedframework.message.IMessage;

import java.sql.Connection;

public class ConnectionAction extends AbstractAction implements
		IConnectionAction {

	public void doAction(IMessage message) {
		log.debug("Speed engine is GetConnection...");

		Connection con = (Connection) this.executor.getConnection();

		try {
			con.setAutoCommit(message.getParamEntity().isCommit());
		} catch (Exception e) {
			throw new SpeedFrameworkException(e);
		}

		this.result = con;
	}
}