abstractpostinsertgenerator.java

hibernate-3.1.3-all-src.zip 面向对象的访问数据库工具

//$Id: AbstractPostInsertGenerator.java 7265 2005-06-22 04:19:34Z oneovthafew $
package org.hibernate.id;

import java.io.Serializable;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

import org.hibernate.HibernateException;
import org.hibernate.engine.SessionImplementor;
import org.hibernate.exception.JDBCExceptionHelper;
import org.hibernate.pretty.MessageHelper;

/**
 * @author Gavin King
 */
public abstract class AbstractPostInsertGenerator implements PostInsertIdentifierGenerator{

	public Serializable generate(SessionImplementor s, Object obj) {
		return IdentifierGeneratorFactory.POST_INSERT_INDICATOR;
	}
	
	protected abstract String getSQL(PostInsertIdentityPersister persister);
	
	protected void bindParameters(SessionImplementor session, PreparedStatement ps, Object object, PostInsertIdentityPersister persister)
	throws SQLException {}
	
	protected abstract Serializable getResult(SessionImplementor session, ResultSet rs, Object object, PostInsertIdentityPersister persister)
	throws SQLException;

	public Serializable getGenerated(SessionImplementor session, Object object, PostInsertIdentityPersister persister) 
	throws HibernateException {
		
		final String sql = getSQL(persister);

		try {
	
			//fetch the generated id in a separate query
			PreparedStatement idSelect = session.getBatcher().prepareStatement(sql);
			try {
				bindParameters(session, idSelect, object, persister);
				ResultSet rs = idSelect.executeQuery();
				try {
					return getResult(session, rs, object, persister);
				}
				finally {
					rs.close();
				}
			}
			finally {
				session.getBatcher().closeStatement(idSelect);
			}
	
		}
		catch ( SQLException sqle ) {
			throw JDBCExceptionHelper.convert(
					session.getFactory().getSQLExceptionConverter(),
					sqle,
					"could not insert: " + MessageHelper.infoString( persister ),
			        sql
				);
		}

	}

}