sql2java-sql

package gu.sql2java.manager; import java.lang.reflect.Array; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.SQLIntegrityConstraintViolationException; import java.sql.Statement; import java.util.ArrayList; import java.util.Arrays; import java.util.Collection; import java.util.Collections; import java.util.HashMap; import java.util.LinkedHashMap; import java.util.LinkedHashSet; import java.util.List; import java.util.Map; import java.util.Map.Entry; import java.util.Objects; import java.util.concurrent.Callable; import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicLong; import com.google.common.base.Function; import com.google.common.base.Joiner; import com.google.common.base.MoreObjects; import com.google.common.base.Predicates; import com.google.common.base.Throwables; import com.google.common.collect.ImmutableBiMap; import com.google.common.collect.ImmutableMap; import com.google.common.collect.Iterables; import com.google.common.collect.Lists; import com.google.common.collect.Maps; import com.google.common.collect.Sets; import com.google.common.primitives.Ints; import gu.sql2java.BaseBean; import gu.sql2java.BaseRow; import gu.sql2java.ColumnCodec; import gu.sql2java.Constant; import gu.sql2java.ForeignKeyMetaData; import gu.sql2java.IDataSourceConfig; import gu.sql2java.IndexMetaData; import gu.sql2java.ListenerContainer; import gu.sql2java.RowMetaData; import gu.sql2java.SimpleLog; import gu.sql2java.TableListener; import gu.sql2java.TableManager; import gu.sql2java.ForeignKeyMetaData.ForeignKeyRule; import gu.sql2java.exception.DaoException; import gu.sql2java.exception.DataAccessException; import gu.sql2java.exception.DataRetrievalException; import gu.sql2java.exception.ObjectRetrievalException; import gu.sql2java.exception.OptimisticLockingException; import gu.sql2java.exception.QueueTimeoutException; import gu.sql2java.exception.RuntimeDaoException; import gu.sql2java.geometry.GeometryDataCodec; import gu.sql2java.manager.Manager.AutoKeyRetrieveType; import gu.sql2java.manager.parser.ParserSupport; import static com.google.common.base.Preconditions.*; import static gu.sql2java.SimpleLog.*; import static gu.sql2java.exception.DaoException.stripSQLException; import static gu.sql2java.manager.Managers.*; import static com.google.common.base.MoreObjects.firstNonNull; import static com.google.common.base.Preconditions.checkNotNull; import static gu.sql2java.Sql2javaSupport.hasNull; import static gu.sql2java.Sql2javaSupport.hasNullPk; /** * implementation of {@link TableManager} * @author guyadong * * @param <B> java bean type */ public class BaseTableManager<B extends BaseBean> implements TableManager<B>,Constant{ protected final RowMetaData metaData; private volatile Manager manager; /** lazy load */ private volatile Map<String,TableListener<BaseBean>> foreignKeyDeleteListeners; /** lazy load */ private volatile ListenerContainerLocal<B> listenerContainer; /** lazy load */ private volatile String generatedkeyStatement; private static boolean debug = false; protected BaseTableManager(String tablename){ metaData = RowMetaData.getMetaData(tablename); } @Override public ListenerContainer<B> getListenerContainer() { // double checking if(listenerContainer == null){ synchronized (this) { if(listenerContainer == null){ listenerContainer = new ListenerContainerLocal<B>(getManager().getFireType()); } } } return listenerContainer; } @Override public IDataSourceConfig getDataSourceConfig(){ return getManager().config; } /** * @return map with foreignKey name TO TableListener */ public Map<String, TableListener<BaseBean>> getForeignKeyDeleteListeners(){ // double checking if(foreignKeyDeleteListeners == null){ synchronized (this) { if(foreignKeyDeleteListeners == null){ LinkedHashMap<String, TableListener<BaseBean>> map = Maps.newLinkedHashMap(); for(ForeignKeyMetaData fk : metaData.getForeignKeysForListener()){ map.put(fk.name, new DeleteRuleListener<BaseBean>(fk.name)); } foreignKeyDeleteListeners = Collections.unmodifiableMap(map); } } } return foreignKeyDeleteListeners; } private String getGeneratedkeyStatement(){ // double check if(generatedkeyStatement == null){ synchronized (this) { if(generatedkeyStatement == null){ generatedkeyStatement = checkNotNull(getManager().getGeneratedkeyStatement(),"INVALID generatedkeyStatement") .replaceAll("<TABLE>", metaData.tablename ) .replaceAll("<KEY>", metaData.columnNameOf(metaData.autoincrementColumnId)); if(debug){ log("generatedkeyStatement={}",generatedkeyStatement); } } } } return generatedkeyStatement; } @Override @SuppressWarnings("unchecked") public final B createBean() { try { return (B) metaData.beanType.newInstance(); } catch (Exception e) { Throwables.throwIfUnchecked(e); throw new RuntimeException(e); } } /** * Creates a new B instance. * @param primaryValues values of primary keys * @return B instance OR null if exist null value in primaryValues */ protected final B createBean(Object... primaryValues) { checkArgument(primaryValues != null && primaryValues.length== metaData.primaryKeyNames.length,"INVALID primaryValues"); B bean = createBean(); int[] pkIds = metaData.primaryKeyIds; for(int i=0;i<primaryValues.length;++i){ int columnId = pkIds[i]; Object value = primaryValues[i]; if(null == value) { return null; } try { bean.setValue(columnId, value); } catch (RuntimeException e) { throw new IllegalArgumentException( String.format("INVALID primkey type %s for %s.%s,Cased by %s", value.getClass().getName(), metaData.tablename, metaData.columnNameOf(columnId), e.getMessage()), e); } } return bean; } private void prepareAutoincrement( Connection c,PreparedStatement ps, B bean) throws SQLException { if (!bean.isModified(metaData.autoincrementColumnId)) { PreparedStatement ps2 = null; ResultSet rs = null; try { AutoKeyRetrieveType retrieveType = getManager().getGeneratedkeyRetrieveType(); if(AutoKeyRetrieveType.auto.equals(retrieveType)){ rs = ps.getGeneratedKeys(); }else{ ps2 = getManager().getStatementCache().prepareStatement(c, getGeneratedkeyStatement(), false, false, null); rs = ps2.executeQuery(); } if(rs.next()) { setColumnValue(bean, metaData.autoincrementColumnId, getManager().getObject(rs,1,metaData.fieldTypeOf(metaData.autoincrementColumnId))); } else { throw new IllegalStateException(logString("ATTENTION: Could not retrieve generated key!(retrieveType:{})",retrieveType)); } } finally { getManager().close(ps2, rs); } } } //13 /** * Insert the B bean into the database. * * @param bean the B bean to be saved * @return the inserted bean * @throws RuntimeDaoException */ protected B insert(final B bean) { // mini checks if (null == bean || !bean.beModified()) { return bean; } String productName = this.getManager().getProductName(); if (!bean.isNew() && !productName.equals(PRODUCT_NAME_PHOENIX)){ return this.update(bean); } Connection c = null; PreparedStatement ps = null; try { c = this.getConnection(); final AutoKeyRetrieveType retrieveType = getManager().getGenerated