Apache
/
openjpa
mirror of https://github.com/apache/openjpa.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

OPENJPA-2099: Reuse internal select by parameter rebinding 

git-svn-id: https://svn.apache.org/repos/asf/openjpa/trunk@1229690 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Pinaki Poddar 2012-01-10 19:08:31 +00:00
parent 6289157f9c
commit 2846f873c2
8 changed files with 308 additions and 237 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

68
openjpa-jdbc/src/main/java/org/apache/openjpa/jdbc/meta/strats/StoreCollectionFieldStrategy.java
View File

@ -39,10 +39,10 @@ import org.apache.openjpa.jdbc.sql.Joins;
import org.apache.openjpa.jdbc.sql.Result;
import org.apache.openjpa.jdbc.sql.Select;
import org.apache.openjpa.jdbc.sql.SelectExecutor;
import org.apache.openjpa.jdbc.sql.SelectImpl;
import org.apache.openjpa.jdbc.sql.Union;
import org.apache.openjpa.kernel.OpenJPAStateManager;
import org.apache.openjpa.kernel.StateManagerImpl;
import org.apache.openjpa.lib.util.Localizer;
import org.apache.openjpa.meta.ClassMetaData;
import org.apache.openjpa.meta.JavaTypes;
import org.apache.openjpa.util.ChangeTracker;
@ -60,8 +60,10 @@ import org.apache.openjpa.util.Proxy;
*
* @author Abe White
*/
@SuppressWarnings("serial")
public abstract class StoreCollectionFieldStrategy
extends ContainerFieldStrategy {
protected SelectExecutor _executor;
/**
* Return the foreign key used to join to the owning field for the given
@ -94,8 +96,7 @@ public abstract class StoreCollectionFieldStrategy
*
* @see FieldMapping#joinRelation
*/
protected abstract Joins joinElementRelation(Joins joins,
ClassMapping elem);
protected abstract Joins joinElementRelation(Joins joins, ClassMapping elem);
/**
* Join to the owning field table for the given element mapping from
@ -112,9 +113,9 @@ public abstract class StoreCollectionFieldStrategy
* Convert the field value to a collection. Handles collections and
* arrays by default.
*/
protected Collection toCollection(Object val) {
protected Collection<?> toCollection(Object val) {
if (field.getTypeCode() == JavaTypes.COLLECTION)
return (Collection) val;
return (Collection<?>) val;
return JavaTypes.toList(val, field.getElement().getType(), false);
}
@ -159,7 +160,7 @@ public abstract class StoreCollectionFieldStrategy
final ClassMapping[] elems = getIndependentElementMappings(true);
Union union = (Union) sel;
if (fetch.getSubclassFetchMode(field.getElementMapping().
getTypeMapping()) != fetch.EAGER_JOIN)
getTypeMapping()) != JDBCFetchConfiguration.EAGER_JOIN)
union.abortUnion();
union.select(new Union.Selector() {
public void select(Select sel, int idx) {
@ -180,8 +181,7 @@ public abstract class StoreCollectionFieldStrategy
if (fetch.hasFetchInnerJoin(field.getFullName(false)))
outer = false;
selectEager(sel, getDefaultElementMapping(true), sm, store, fetch,
JDBCFetchConfiguration.EAGER_JOIN, false,
outer);
JDBCFetchConfiguration.EAGER_JOIN, false, outer);
}
public boolean isEagerSelectToMany() {
@ -194,7 +194,7 @@ public abstract class StoreCollectionFieldStrategy
private void selectEager(Select sel, ClassMapping elem,
OpenJPAStateManager sm, JDBCStore store, JDBCFetchConfiguration fetch,
int eagerMode, boolean selectOid, boolean outer) {
// force distinct if there was a to-many join to avoid dups, but
// force distinct if there was a to-many join to avoid duplicates, but
// if this is a parallel select don't make distinct based on the
// eager joins alone if the original wasn't distinct
if (eagerMode == JDBCFetchConfiguration.EAGER_PARALLEL) {
@ -214,8 +214,7 @@ public abstract class StoreCollectionFieldStrategy
joins = join(joins, elem);
// order, ref cols
if (field.getOrderColumn() != null || field.getOrders().length > 0
|| !selectOid) {
if (field.getOrderColumn() != null || field.getOrders().length > 0 || !selectOid) {
if (outer)
joins = sel.outer(joins);
if (!selectOid) {
@ -360,14 +359,11 @@ public abstract class StoreCollectionFieldStrategy
// get the StateManager of this toMany value
// and find the value of the inverse mappedBy field (Customer)
// for this toMacdny field
PersistenceCapable pc = (PersistenceCapable)
((Collection) coll).iterator().next();
OpenJPAStateManager sm1 = (OpenJPAStateManager) pc.
pcGetStateManager();
PersistenceCapable pc = (PersistenceCapable)((Collection) coll).iterator().next();
OpenJPAStateManager sm1 = (OpenJPAStateManager) pc.pcGetStateManager();
ClassMapping clm = ((ClassMapping) sm1.getMetaData());
FieldMapping fm = (FieldMapping) clm.getField(
mappedByFieldMapping.getName());
FieldMapping fm = (FieldMapping) clm.getField(mappedByFieldMapping.getName());
if (fm == mappedByFieldMapping)
res.setMappedByValue(sm1.fetchObject(fm.getIndex()));
} else {
@ -513,8 +509,7 @@ public abstract class StoreCollectionFieldStrategy
Result res = sel.execute(store, fetch);
try {
res.next();
coll.getChangeTracker().setNextSequence
(res.getInt(field) + 1);
coll.getChangeTracker().setNextSequence(res.getInt(field) + 1);
} finally {
res.close();
}
@ -522,17 +517,20 @@ public abstract class StoreCollectionFieldStrategy
sm.storeObjectField(field.getIndex(), coll);
return;
}
// select data for this sm
// select data for this state manager
final ClassMapping[] elems = getIndependentElementMappings(true);
final Joins[] resJoins = new Joins[Math.max(1, elems.length)];
Union union = store.getSQLFactory().newUnion
(Math.max(1, elems.length));
Union union;
if (_executor == null) {
union = store.getSQLFactory().newUnion(Math.max(1, elems.length));
_executor = union;
} else {
union = (Union)_executor;
}
union.select(new Union.Selector() {
public void select(Select sel, int idx) {
ClassMapping elem = (elems.length == 0) ? null : elems[idx];
resJoins[idx] = selectAll(sel, elem, sm, store, fetch,
JDBCFetchConfiguration.EAGER_PARALLEL);
resJoins[idx] = selectAll(sel, elem, sm, store, fetch, JDBCFetchConfiguration.EAGER_PARALLEL);
}
});
@ -555,8 +553,7 @@ public abstract class StoreCollectionFieldStrategy
if (ct != null && field.getOrderColumn() != null)
seq = res.getInt(field.getOrderColumn());
setMappedBy(sm.getObjectId(), sm, coll, res);
add(store, coll, loadElement(sm, store, fetch, res,
resJoins[res.indexOf()]));
add(store, coll, loadElement(sm, store, fetch, res, resJoins[res.indexOf()]));
}
if (ct != null && field.getOrderColumn() != null)
ct.setNextSequence(seq + 1);
@ -565,12 +562,13 @@ public abstract class StoreCollectionFieldStrategy
}
// set into sm
if (field.getTypeCode() == JavaTypes.ARRAY)
if (field.getTypeCode() == JavaTypes.ARRAY) {
sm.storeObject(field.getIndex(), JavaTypes.toArray
((Collection) coll, field.getElement().getType()));
else
} else {
sm.storeObject(field.getIndex(), coll);
}
}
/**
* Select data for loading, starting in field table.
@ -581,13 +579,17 @@ public abstract class StoreCollectionFieldStrategy
ForeignKey fk = getJoinForeignKey(elem);
Object oid = getObjectIdForJoin(fk, sm);
sel.whereForeignKey(fk, oid, field.getDefiningMapping(), store);
Joins joins;
if (!sel.isReadOnly()) {
// order first, then select so that if the projection introduces
// additional ordering, it will be after our required ordering
field.orderLocal(sel, elem, null);
Joins joins = joinElementRelation(sel.newJoins(), elem);
joins = joinElementRelation(sel.newJoins(), elem);
field.orderRelation(sel, elem, joins);
selectElement(sel, elem, store, fetch, eagerMode, joins);
} else {
joins = joinElementRelation(sel.newJoins(), elem);
}
return joins;
}
@ -624,4 +626,8 @@ public abstract class StoreCollectionFieldStrategy
}
return oid;
}
public String toString() {
return getClass().getSimpleName() + '[' + field.getName() + ']';
}
}

26
openjpa-jdbc/src/main/java/org/apache/openjpa/jdbc/sql/AbstractResult.java
View File

@ -74,7 +74,7 @@ public abstract class AbstractResult
private static final Joins JOINS = new NoOpJoins();
private Map _eager = null;
private Map<Object,Object> _eager = null;
private ClassMapping _base = null;
private int _index = 0;
private boolean _gotEager = false;
@ -86,14 +86,14 @@ public abstract class AbstractResult
private Object _mappedByValue = null;
public Object getEager(FieldMapping key) {
Map map = getEagerMap(true);
Map<Object,Object> map = getEagerMap(true);
return (map == null) ? null : map.get(key);
}
public void putEager(FieldMapping key, Object res) {
Map map = getEagerMap(false);
Map<Object,Object> map = getEagerMap(false);
if (map == null) {
map = new HashMap();
map = new HashMap<Object,Object>();
setEagerMap(map);
}
map.put(key, res);
@ -104,7 +104,7 @@ public abstract class AbstractResult
*
* @param client whether the client is accessing eager information
*/
protected Map getEagerMap(boolean client) {
protected Map<Object,Object> getEagerMap(boolean client) {
if (client)
_gotEager = true;
return _eager;
@ -113,7 +113,7 @@ public abstract class AbstractResult
/**
* Raw eager information.
*/
protected void setEagerMap(Map eager) {
protected void setEagerMap(Map<Object,Object> eager) {
_eager = eager;
}
@ -129,11 +129,9 @@ public abstract class AbstractResult
/**
* Close all results in eager map.
*/
protected void closeEagerMap(Map eager) {
protected void closeEagerMap(Map<Object,Object> eager) {
if (eager != null) {
Object res;
for (Iterator itr = eager.values().iterator(); itr.hasNext();) {
res = itr.next();
for (Object res : eager.values()) {
if (res != this && res instanceof Closeable)
try {
((Closeable) res).close();
@ -891,9 +889,6 @@ public abstract class AbstractResult
return this;
}
public void appendTo(SQLBuffer buf) {
}
public Joins setCorrelatedVariable(String var) {
return this;
}
@ -904,5 +899,10 @@ public abstract class AbstractResult
public void moveJoinsToParent() {
}
@Override
public StringBuilder path() {
return null;
}
}
}

41
openjpa-jdbc/src/main/java/org/apache/openjpa/jdbc/sql/JoinSet.java
View File

@ -39,9 +39,9 @@ class JoinSet {
// efficient representation with O(1) lookup, add, remove operations for
// typical sets of joins, and it means we'd have to create a graph anyway
// when joinIterator() is called
private final List _graph = new ArrayList();
private final List<Node> _graph = new ArrayList<Node>();
private int _size = 0;
private List _sorted = null;
private List<Join> _sorted = null;
public JoinSet() {
}
@ -51,7 +51,7 @@ class JoinSet {
if (copy._graph.get(i) == null)
_graph.add(null);
else
_graph.add(((Node) copy._graph.get(i)).clone());
_graph.add((Node) copy._graph.get(i).clone());
}
_size = copy._size;
_sorted = copy._sorted;
@ -95,23 +95,22 @@ class JoinSet {
/**
* Iterator over joins that prepares them for SQL translation.
*/
public Iterator joinIterator() {
public Iterator<Join> joinIterator() {
if (_size < 2)
return iterator();
if (_sorted != null)
return _sorted.iterator();
List sorted = new ArrayList(_size);
LinkedList queue = new LinkedList();
BitSet seen = new BitSet(_graph.size() * _graph.size()
+ _graph.size());
List<Join> sorted = new ArrayList<Join>(_size);
LinkedList<Node> queue = new LinkedList<Node>();
BitSet seen = new BitSet(_graph.size() * _graph.size() + _graph.size());
// traverse graph
Node n;
int idx, sidx;
for (int i = 0; i < _graph.size(); i++) {
// seed queue with next set of disconnected joins
for (n = (Node) _graph.get(i); n != null; n = n.next) {
for (n = _graph.get(i); n != null; n = n.next) {
sidx = getSeenIndex(n.join);
if (!seen.get(sidx)) {
seen.set(sidx);
@ -183,8 +182,8 @@ class JoinSet {
return false;
boolean added = false;
for (Iterator itr = js.iterator(); itr.hasNext();)
added = add((Join) itr.next()) || added;
for (Iterator<Join> itr = js.iterator(); itr.hasNext();)
added = add(itr.next()) || added;
return added;
}
@ -218,8 +217,8 @@ class JoinSet {
_size++;
}
public Iterator iterator() {
return new Iterator() {
public Iterator<Join> iterator() {
return new Iterator<Join>() {
private Node _next = null;
private int _idx = -1;
@ -237,7 +236,7 @@ class JoinSet {
return false;
}
public Object next() {
public Join next() {
if (!hasNext())
throw new NoSuchElementException();
Join j = _next.join;
@ -289,16 +288,16 @@ class JoinSet {
public boolean removeAll(JoinSet js) {
boolean remd = false;
for (Iterator itr = js.iterator(); itr.hasNext();)
remd = remove((Join) itr.next()) || remd;
for (Iterator<Join> itr = js.iterator(); itr.hasNext();)
remd = remove(itr.next()) || remd;
return remd;
}
public boolean retainAll(JoinSet js) {
boolean remd = false;
Join join;
for (Iterator itr = iterator(); itr.hasNext();) {
join = (Join) itr.next();
for (Iterator<Join> itr = iterator(); itr.hasNext();) {
join = itr.next();
if (!js.contains(join))
remd = remove(join);
}
@ -318,8 +317,8 @@ class JoinSet {
public boolean containsAll(JoinSet js) {
if (js._size > _size || js._graph.size() > _graph.size())
return false;
for (Iterator itr = js.iterator(); itr.hasNext();)
if (!contains((Join) itr.next()))
for (Iterator<Join> itr = js.iterator(); itr.hasNext();)
if (!contains(itr.next()))
return false;
return true;
}
@ -347,7 +346,7 @@ class JoinSet {
public String toString() {
StringBuilder buf = new StringBuilder();
buf.append("[");
for (Iterator itr = iterator(); itr.hasNext();) {
for (Iterator<Join> itr = iterator(); itr.hasNext();) {
buf.append("<").append(itr.next()).append(">");
if (itr.hasNext())
buf.append(", ");

6
openjpa-jdbc/src/main/java/org/apache/openjpa/jdbc/sql/Joins.java
View File

@ -102,4 +102,10 @@ public interface Joins {
* Move joins that belong to subquery's parent
*/
public void moveJoinsToParent();
/**
* Gets the current path as a mutable string.
* @return
*/
public StringBuilder path();
}

4
openjpa-jdbc/src/main/java/org/apache/openjpa/jdbc/sql/LogicalUnion.java
View File

@ -915,6 +915,10 @@ public class LogicalUnion
public DBDictionary getDictionary() {
return dict;
}
public boolean isReadOnly() {
return sel.isReadOnly();
}
}
/**

21
openjpa-jdbc/src/main/java/org/apache/openjpa/jdbc/sql/SQLBuffer.java
View File

@ -584,4 +584,25 @@ public final class SQLBuffer
}
}
/**
* Binds the given value to a parameter representing the given column.
* The column must be bound before this call.
* @param o a parameter value
* @param col a column to which the value is to be bound
* @return this same buffer
* @exception IllegalArgumentException is no parameter represents the given column
*/
public SQLBuffer bind(Object o, Column col) {
boolean bound = false;
for (int i = 0; i < _params.size(); i++) {
BindParameter param = _params.get(i);
if (param.getColumn() == col) {
param.setValue(o);
bound = true;
}
}
if (!bound)
throw new IllegalArgumentException("Column " + col + " does not exist to bind " + o);
return this;
}
}

28
openjpa-jdbc/src/main/java/org/apache/openjpa/jdbc/sql/Select.java
View File

@ -751,22 +751,42 @@ public interface Select
/**
* Set joined table metadatas for polymorphic queries
*/
public void setJoinedTableClassMeta(List meta);
public void setJoinedTableClassMeta(List<ClassMapping> meta);
/**
* get joined table metadatas for polymorphic queries
*/
public List getJoinedTableClassMeta();
public List<ClassMapping> getJoinedTableClassMeta();
/**
* Set joined table metadatas excluded for polymorphic queries
*/
public void setExcludedJoinedTableClassMeta(List meta);
public void setExcludedJoinedTableClassMeta(List<ClassMapping> meta);
/**
* get joined table metadatas excluded for polymorphic queries
*/
public List getExcludedJoinedTableClassMeta();
public List<ClassMapping> getExcludedJoinedTableClassMeta();
/**
* Gets the database dictionary used by this select to form the target SQL
* statement.
*
* @return the immutable database dictionary.
*/
public DBDictionary getDictionary() ;
/**
* Affirms if this select is structurally immutable.
* A select becomes immutable upon {@link #execute(JDBCStore, JDBCFetchConfiguration) execution}.
* There is no explicit way to turn a select into read-only status.
* <br>
* The immutable contract does not prevent {@link SQLBuffer#bind(Object, Column) binding}
* new values to {@link BindParameter parameters}.
*
* @return false on construction, true after execution.
*
* @since 2.2.0
*/
boolean isReadOnly();
}

323
openjpa-jdbc/src/main/java/org/apache/openjpa/jdbc/sql/SelectImpl.java
View File

@ -39,7 +39,6 @@ import java.util.Stack;
import java.util.TreeMap;
import org.apache.commons.collections.iterators.EmptyIterator;
import org.apache.commons.lang.StringUtils;
import org.apache.openjpa.jdbc.conf.JDBCConfiguration;
import org.apache.openjpa.jdbc.kernel.EagerFetchModes;
import org.apache.openjpa.jdbc.kernel.JDBCFetchConfiguration;
@ -117,15 +116,15 @@ public class SelectImpl
// field of type Address:
// 'address.street' should map to a different table alias than
// 'parent.address.street' for the purposes of comparisons
private Map _aliases = null;
private Map<Object,Integer> _aliases = null;
// map of indexes to table aliases like 'TABLENAME t0'
private SortedMap _tables = null;
private SortedMap<Integer,String> _tables = null;
// combined list of selected ids and map of each id to its alias
protected final Selects _selects = newSelects();
private List _ordered = null;
private List _grouped = null;
private List<Object> _ordered = null;
private List<Object> _grouped = null;
// flags
private int _flags = 0;
@ -147,15 +146,15 @@ public class SelectImpl
// joins to add to the end of our where clause, and joins to prepend to
// all selects (see select(classmapping) method)
private SelectJoins _joins = null;
private Stack _preJoins = null;
private Stack<PathJoins> _preJoins = null;
// map of joins+keys to eager selects and global set of eager keys; the
// same key can't be used more than once
private Map _eager = null;
private Set _eagerKeys = null;
private Map<Object,SelectExecutor> _eager = null;
private Set<FieldMapping> _eagerKeys = null;
// subselect support
private List<SelectImpl> _subsels = null;
private List<Select> _subsels = null;
private SelectImpl _parent = null;
private String _subPath = null;
private boolean _hasSub = false;
@ -170,8 +169,10 @@ public class SelectImpl
// A path navigation is begin with this schema alias
private String _schemaAlias = null;
private ClassMapping _tpcMeta = null;
private List _joinedTables = null;
private List _exJoinedTables = null;
private List<ClassMapping> _joinedTables = null;
private List<ClassMapping> _exJoinedTables = null;
private boolean _readOnly = false;
public ClassMapping getTablePerClassMeta() {
return _tpcMeta;
@ -180,19 +181,19 @@ public class SelectImpl
_tpcMeta = meta;
}
public void setJoinedTableClassMeta(List meta) {
public void setJoinedTableClassMeta(List<ClassMapping> meta) {
_joinedTables = meta;
}
public List getJoinedTableClassMeta() {
public List<ClassMapping> getJoinedTableClassMeta() {
return _joinedTables;
}
public void setExcludedJoinedTableClassMeta(List meta) {
public void setExcludedJoinedTableClassMeta(List<ClassMapping> meta) {
_exJoinedTables = meta;
}
public List getExcludedJoinedTableClassMeta() {
public List<ClassMapping> getExcludedJoinedTableClassMeta() {
return _exJoinedTables;
}
@ -341,10 +342,8 @@ public class SelectImpl
public boolean hasMultipleSelects() {
if (_eager == null)
return false;
Map.Entry entry;
for (Iterator itr = _eager.entrySet().iterator(); itr.hasNext();) {
entry = (Map.Entry) itr.next();
if (entry.getValue() != this)
for (Iterator<Map.Entry<Object,SelectExecutor>> itr = _eager.entrySet().iterator(); itr.hasNext();) {
if (itr.next().getValue() != this)
return true;
}
return false;
@ -429,7 +428,11 @@ public class SelectImpl
try { conn.close(); } catch (SQLException se2) {}
throw se;
}
try {
return getEagerResult(conn, stmnt, rs, store, fetch, forUpdate, sql);
} finally {
makeReadOnly();
}
}
/**
@ -443,11 +446,9 @@ public class SelectImpl
return;
// execute eager selects
Map.Entry entry;
Result eres;
Map eager;
for (Iterator itr = sel._eager.entrySet().iterator(); itr.hasNext();) {
entry = (Map.Entry) itr.next();
Map<Object,Object> eager;
for (Map.Entry<Object,SelectExecutor> entry : sel._eager.entrySet()) {
// simulated batched selects for inner/outer joins; for separate
// selects, don't pass on lock level, because they're probably
@ -455,12 +456,11 @@ public class SelectImpl
if (entry.getValue() == sel)
eres = res;
else
eres = ((SelectExecutor) entry.getValue()).execute(store,
fetch);
eres = entry.getValue().execute(store, fetch);
eager = res.getEagerMap(false);
if (eager == null) {
eager = new HashMap();
eager = new HashMap<Object,Object>();
res.setEagerMap(eager);
}
eager.put(entry.getKey(), eres);
@ -547,8 +547,10 @@ public class SelectImpl
return 0;
}
public List getSubselects() {
return (_subsels == null) ? Collections.EMPTY_LIST : _subsels;
public List<Select> getSubselects() {
if (_subsels == null)
return Collections.emptyList();
return _subsels;
}
public Select getParent() {
@ -579,7 +581,7 @@ public class SelectImpl
_parent = (SelectImpl) parent;
if (_parent != null) {
if (_parent._subsels == null)
_parent._subsels = new ArrayList(2);
_parent._subsels = new ArrayList<Select>(2);
_parent._subsels.add(this);
if (_parent._joinSyntax == JoinSyntaxes.SYNTAX_SQL92)
_joinSyntax = JoinSyntaxes.SYNTAX_TRADITIONAL;
@ -596,7 +598,7 @@ public class SelectImpl
return _hasSub;
}
public Map getAliases() {
public Map<Object,Integer> getAliases() {
return _aliases;
}
@ -604,7 +606,7 @@ public class SelectImpl
_aliases.remove(key);
}
public Map getTables() {
public Map<Integer,String> getTables() {
return _tables;
}
@ -641,19 +643,21 @@ public class SelectImpl
return getTableIndex(table, pj, false) != -1;
}
public Collection getTableAliases() {
return (_tables == null) ? Collections.EMPTY_SET : _tables.values();
public Collection<String> getTableAliases() {
if (_tables == null)
return Collections.emptySet();
return _tables.values();
}
public List getSelects() {
public List<Object> getSelects() {
return Collections.unmodifiableList(_selects);
}
public List getSelectAliases() {
public List<Object> getSelectAliases() {
return _selects.getAliases(false, _outer != null);
}
public List getIdentifierAliases() {
public List<Object> getIdentifierAliases() {
return _selects.getAliases(true, _outer != null);
}
@ -679,8 +683,8 @@ public class SelectImpl
// join set iterator allows concurrent modification
Join j;
for (Iterator itr = _joins.joins().iterator(); itr.hasNext();) {
j = (Join) itr.next();
for (Iterator<Join> itr = _joins.joins().iterator(); itr.hasNext();) {
j = itr.next();
if (j.getRelationTarget() != null) {
j.getRelationTarget().getDiscriminator().addClassConditions
(this, j.getSubclasses() == SUBS_JOINABLE,
@ -694,7 +698,7 @@ public class SelectImpl
return _joins;
}
public Iterator getJoinIterator() {
public Iterator<Join> getJoinIterator() {
if (_joins == null || _joins.isEmpty())
return EmptyIterator.INSTANCE;
return _joins.joins().joinIterator();
@ -742,9 +746,9 @@ public class SelectImpl
public String getColumnAlias(Column col, Object path) {
Table table = col.getTable();
String tableAlias = null;
Iterator itr = getJoinIterator();
Iterator<Join> itr = getJoinIterator();
while (itr.hasNext()) {
Join join = (Join) itr.next();
Join join = itr.next();
if (join != null) {
if (join.getTable1() == table)
tableAlias = join.getAlias1();
@ -951,6 +955,7 @@ public class SelectImpl
void select(Select wrapper, ClassMapping mapping, int subclasses,
JDBCStore store, JDBCFetchConfiguration fetch, int eager,
Joins joins, boolean ident) {
assertMutable();
// note that this is one case where we don't want to use the result
// of getJoins(); just use the given joins, which will either be clean
// or the result of previous pre-joins. this way we don't push extra
@ -967,7 +972,7 @@ public class SelectImpl
boolean hasJoins = pj != null && pj.isDirty();
if (hasJoins) {
if (_preJoins == null)
_preJoins = new Stack();
_preJoins = new Stack<PathJoins>();
_preJoins.push(pj);
}
@ -1098,6 +1103,7 @@ public class SelectImpl
*/
private boolean columnOperation(Column col, boolean sel, Boolean asc,
PathJoins pj, boolean aliasOrder) {
assertMutable();
String as = null;
if (asc != null && (aliasOrder || (_flags & RECORD_ORDERED) != 0)) {
Object id;
@ -1107,7 +1113,7 @@ public class SelectImpl
id = getColumnAlias(col, pj);
if ((_flags & RECORD_ORDERED) != 0) {
if (_ordered == null)
_ordered = new ArrayList(5);
_ordered = new ArrayList<Object>(5);
_ordered.add(id);
}
if (aliasOrder) {
@ -1224,6 +1230,7 @@ public class SelectImpl
*/
private boolean orderBy(Object sql, boolean asc, Joins joins, boolean sel,
boolean aliasOrder, Value selAs) {
assertMutable();
Object order = sql;
if (aliasOrder) {
order = toOrderAlias(_orders++);
@ -1231,7 +1238,7 @@ public class SelectImpl
}
if ((_flags & RECORD_ORDERED) != 0) {
if (_ordered == null)
_ordered = new ArrayList(5);
_ordered = new ArrayList<Object>(5);
_ordered.add(selAs == null ? sql : selAs);
}
@ -1284,10 +1291,10 @@ public class SelectImpl
* Return the indexes in the select list of all items we're ordering
* by, or null if none. For use with unions.
*/
List getOrderedIndexes() {
List<Integer> getOrderedIndexes() {
if (_ordered == null)
return null;
List idxs = new ArrayList(_ordered.size());
List<Integer> idxs = new ArrayList<Integer>(_ordered.size());
for (int i = 0; i < _ordered.size(); i++)
idxs.add(_selects.indexOf(_ordered.get(i)));
return idxs;
@ -1376,16 +1383,17 @@ public class SelectImpl
}
SQLBuffer buf = new SQLBuffer(_dict);
SQLBuffer buf = isReadOnly() ? _where : new SQLBuffer(_dict);
Object[] params = getBindParameter(oid, mapping, toCols, fromCols, pj, store);
bindParameter(buf, params, fromCols, pj);
if (constCols != null && constCols.length > 0) {
bindParameter(buf, vals, constCols, pj);
}
if (buf != _where) {
where(buf, pj);
}
}
/**
* Gets the binding parameter values to join the given object identifier.
@ -1423,16 +1431,26 @@ public class SelectImpl
/**
* Binds the parameters to the given SQL buffer.
* @param buf
* @param params
* @param fromCols
* @param pj
* @param buf a sql buffer
* @param params the parameter values to bind
* @param fromCols the corresponding columns to which the parameters bind. Same size of the values.
* @param pj the joins, if any, for the columns
*/
void bindParameter(SQLBuffer buf, Object[] params, Column[] fromCols, PathJoins pj) {
if (isReadOnly()) {
for (int i = 0; i < params.length; i++) {
buf.bind(params[i], fromCols[i]);
}
return;
}
for (int i = 0; i < params.length; i++) {
if (i > 0)
buf.append(" AND ");
buf.append(getColumnAlias(fromCols[i], pj));
// WARNING: Potential bug hides here
// A parameter value appearing as null and non-null in two binding operation
// will expose this bug. Requires more structure to BindParameter to accept
// an opcode.
buf.append(params[i] == null ? " IS " : " = ");
buf.appendValue(params[i], fromCols[i]);
}
@ -1551,7 +1569,7 @@ public class SelectImpl
if (_grouped == null || !_grouped.contains(sql)) {
if (_grouping == null) {
_grouping = new SQLBuffer(_dict);
_grouped = new ArrayList();
_grouped = new ArrayList<Object>();
} else
_grouping.append(", ");
@ -1641,9 +1659,9 @@ public class SelectImpl
sel._joinSyntax = _joinSyntax;
sel._schemaAlias = _schemaAlias;
if (_aliases != null)
sel._aliases = new HashMap(_aliases);
sel._aliases = new HashMap<Object,Integer>(_aliases);
if (_tables != null)
sel._tables = new TreeMap(_tables);
sel._tables = new TreeMap<Integer,String>(_tables);
if (_joins != null)
sel._joins = _joins.clone(sel);
if (_where != null)
@ -1653,7 +1671,7 @@ public class SelectImpl
sel._from._outer = sel;
}
if (_subsels != null) {
sel._subsels = new ArrayList(_subsels.size());
sel._subsels = new ArrayList<Select>(_subsels.size());
SelectImpl sub, selSub;
for (int j = 0; j < _subsels.size(); j++) {
sub = (SelectImpl) _subsels.get(j);
@ -1717,7 +1735,7 @@ public class SelectImpl
// global set of eager keys
if (_eagerKeys == null)
_eagerKeys = new HashSet();
_eagerKeys = new HashSet<FieldMapping>();
_eagerKeys.add(key);
SelectExecutor sel;
@ -1737,7 +1755,7 @@ public class SelectImpl
}
if (_eager == null)
_eager = new HashMap();
_eager = new HashMap<Object,SelectExecutor>();
_eager.put(toEagerKey(key, getJoins(null, false)), sel);
return sel;
}
@ -1750,9 +1768,8 @@ public class SelectImpl
sel._flags &= ~NONAUTO_DISTINCT;
sel._eagerKeys = _eagerKeys;
if (_preJoins != null && !_preJoins.isEmpty()) {
sel._preJoins = new Stack();
sel._preJoins.push(((SelectJoins) _preJoins.peek()).
clone(sel));
sel._preJoins = new Stack<PathJoins>();
sel._preJoins.push(((SelectJoins) _preJoins.peek()).clone(sel));
}
return sel;
}
@ -1760,7 +1777,7 @@ public class SelectImpl
/**
* Return view of eager selects. May be null.
*/
public Map getEagerMap() {
public Map<Object,SelectExecutor> getEagerMap() {
return _eager;
}
@ -1809,9 +1826,9 @@ public class SelectImpl
if (!buf.isEmpty())
buf.append(" AND ");
Join join = null;
for (Iterator itr = ((PathJoins) joins).joins().joinIterator();
for (Iterator<Join> itr = ((PathJoins) joins).joins().joinIterator();
itr.hasNext();) {
join = (Join) itr.next();
join = itr.next();
switch (_joinSyntax) {
case JoinSyntaxes.SYNTAX_TRADITIONAL:
buf.append(_dict.toTraditionalJoin(join));
@ -1936,8 +1953,8 @@ public class SelectImpl
Join join;
Join rec;
boolean hasJoins = _joins != null && _joins.joins() != null;
for (Iterator itr = pj.joins().iterator(); itr.hasNext();) {
join = (Join) itr.next();
for (Iterator<Join> itr = pj.joins().iterator(); itr.hasNext();) {
join = itr.next();
if (join.getType() == Join.TYPE_INNER) {
if (!hasJoins)
join.setType(Join.TYPE_OUTER);
@ -1969,8 +1986,8 @@ public class SelectImpl
}
Join join;
for (Iterator itr = pj.joins().iterator(); itr.hasNext();) {
join = (Join) itr.next();
for (Iterator<Join> itr = pj.joins().iterator(); itr.hasNext();) {
join = itr.next();
if (join.getType() == Join.TYPE_INNER) {
if (join.getForeignKey() != null
&& !_dict.canOuterJoin(_joinSyntax, join.getForeignKey())) {
@ -1999,7 +2016,7 @@ public class SelectImpl
Integer i = null;
Object key = table.getFullIdentifier().getName();
if (pj != null && pj.path() != null)
key = new Key(pj.getPathStr(), key);
key = new Key(pj.path().toString(), key);
if (_ctx != null && (_parent != null || _subsels != null || _hasSub)) {
i = findAliasForQuery(table, pj, key, create);
@ -2067,11 +2084,11 @@ public class SelectImpl
(corrVar == null || (thisCtx != null && ctx() == thisCtx)));
}
/**
* Find the alias for the key starting lookup in this instance only.
*/
private Integer getAlias(Table table, Object key) {
Integer alias = null;
if (_aliases != null)
alias = (Integer) _aliases.get(key);
return alias;
return _aliases == null ? null : _aliases.get(key);
}
private int createAlias(Table table, Object key) {
@ -2080,21 +2097,16 @@ public class SelectImpl
return i.intValue();
}
/**
* Find the alias for the key starting lookup in this instance and searching the parents
* as well if necessary.
*/
private Integer findAlias(Table table, Object key) {
Integer alias = null;
if (_aliases != null) {
alias = (Integer) _aliases.get(key);
Integer alias = getAlias(table, key);
if (alias != null) {
return alias;
}
}
if (_parent != null) {
alias = _parent.findAlias(table, key);
if (alias != null) {
return alias;
}
}
return alias;
return (_parent != null) ? _parent.findAlias(table, key) : null;
}
/**
@ -2102,13 +2114,13 @@ public class SelectImpl
*/
private void recordTableAlias(Table table, Object key, Integer alias) {
if (_aliases == null)
_aliases = new HashMap();
_aliases = new HashMap<Object,Integer>();
_aliases.put(key, alias);
String tableString = _dict.getFullName(table, false) + " "
+ toAlias(alias.intValue());
if (_tables == null)
_tables = new TreeMap();
_tables = new TreeMap<Integer,String>();
_tables.put(alias, tableString);
}
@ -2122,9 +2134,9 @@ public class SelectImpl
int aliases = (fromParent || _parent == null) ? 0 : _parent.aliasSize(false, this);
aliases += (_aliases == null) ? 0 : _aliases.size();
if (_subsels != null) {
for (SelectImpl sub : _subsels) {
for (Select sub : _subsels) {
if (sub != fromSub)
aliases += sub.aliasSize(true, null);
aliases += ((SelectImpl)sub).aliasSize(true, null);
}
}
return aliases;
@ -2264,10 +2276,6 @@ public class SelectImpl
public String toString() {
return _path + "|" + _key;
}
Object getKey() {
return _key;
}
}
/**
@ -2278,11 +2286,11 @@ public class SelectImpl
implements PathJoins {
private SelectImpl _sel = null;
private Map<Column, Object> cachedColumnAlias_ = null;
private Map<Column, Object> _cachedColumnAlias = null;
// position in selected columns list where we expect the next load
private int _pos = 0;
private Stack _preJoins = null;
private Stack<Joins> _preJoins = null;
/**
* Constructor.
@ -2311,29 +2319,28 @@ public class SelectImpl
// eager results
if (_sel._eager == null || !_sel._eagerKeys.contains(key))
return null;
Map map = SelectResult.this.getEagerMap(true);
Map<Object,Object> map = SelectResult.this.getEagerMap(true);
if (map == null)
return null;
return map.get(_sel.toEagerKey(key, getJoins(null)));
return map.get(SelectImpl.toEagerKey(key, getJoins(null)));
}
public void putEager(FieldMapping key, Object res) {
Map map = SelectResult.this.getEagerMap(true);
Map<Object,Object> map = SelectResult.this.getEagerMap(true);
if (map == null) {
map = new HashMap();
map = new HashMap<Object,Object>();
setEagerMap(map);
}
map.put(_sel.toEagerKey(key, getJoins(null)), res);
map.put(SelectImpl.toEagerKey(key, getJoins(null)), res);
}
public Object load(ClassMapping mapping, JDBCStore store,
JDBCFetchConfiguration fetch, Joins joins)
throws SQLException {
boolean hasJoins = joins != null
&& ((PathJoins) joins).path() != null;
boolean hasJoins = joins != null && ((PathJoins) joins).path() != null;
if (hasJoins) {
if (_preJoins == null)
_preJoins = new Stack();
_preJoins = new Stack<Joins>();
_preJoins.push(joins);
}
@ -2362,9 +2369,9 @@ public class SelectImpl
if (pj != null && pj.path() != null) {
Object columnAlias = getColumnAlias((Column) obj, pj);
if (joins == null) {
if (cachedColumnAlias_ == null)
cachedColumnAlias_ = new HashMap<Column, Object>();
cachedColumnAlias_.put((Column) obj, columnAlias);
if (_cachedColumnAlias == null)
_cachedColumnAlias = new HashMap<Column, Object>();
_cachedColumnAlias.put((Column) obj, columnAlias);
}
return columnAlias != null && _sel._selects.contains(columnAlias);
}
@ -2416,8 +2423,8 @@ public class SelectImpl
if (pj != null && pj.path() != null) {
Column col = (Column) obj;
pk = (col.isPrimaryKey()) ? Boolean.TRUE : Boolean.FALSE;
if (joins == null && cachedColumnAlias_ != null) {
obj = cachedColumnAlias_.get(col);
if (joins == null && _cachedColumnAlias != null) {
obj = _cachedColumnAlias.get(col);
if (obj == null)
obj = getColumnAlias(col, pj);
} else {
@ -2468,6 +2475,8 @@ public class SelectImpl
/**
* Return the joins to use to find column data.
* If the given join is non-null and has a path then it is returned.
* Otherwise, returns the {@link #getPreJoins() pre joins}.
*/
private PathJoins getJoins(Joins joins) {
PathJoins pj = (PathJoins) joins;
@ -2477,7 +2486,7 @@ public class SelectImpl
}
/**
* Return the pre joins for the result, or null if none. Note that
* Return the pre joins for this result, or null if none. Note that
* we have to take the Select's pre joins into account too, since
* batched selects can have additional pre joins on the stack even
* on execution.
@ -2497,15 +2506,14 @@ public class SelectImpl
private String getColumnAlias(Column col, PathJoins pj) {
String alias;
if (_sel._from != null) {
alias = _sel.toAlias(_sel._from.getTableIndex
(col.getTable(), pj, false));
alias = SelectImpl.toAlias(_sel._from.getTableIndex(col.getTable(), pj, false));
if (alias == null)
return null;
if (_sel._dict.requiresAliasForSubselect)
return FROM_SELECT_ALIAS + "." + alias + "_" + col;
return alias + "_" + col;
}
alias = _sel.toAlias(_sel.getTableIndex(col.getTable(), pj, false));
alias = SelectImpl.toAlias(_sel.getTableIndex(col.getTable(), pj, false));
return (alias == null) ? null : alias + "." + col;
}
@ -2611,7 +2619,6 @@ public class SelectImpl
protected String correlatedVar = null;
protected Context context = null;
protected Context lastContext = null;
protected String pathStr = null;
public Select getSelect() {
return null;
@ -2649,10 +2656,6 @@ public class SelectImpl
return this;
}
public String getVariable() {
return var;
}
public Joins setCorrelatedVariable(String var) {
this.correlatedVar = var;
return this;
@ -2716,20 +2719,12 @@ public class SelectImpl
path = new StringBuilder(str);
else
path.append('.').append(str);
pathStr = null;
}
}
public String getPathStr() {
if (pathStr == null) {
pathStr = path.toString();
}
return pathStr;
}
public String toString() {
return "PathJoinsImpl<" + hashCode() + ">: "
+ String.valueOf(path);
return "PathJoinsImpl<" + hashCode() + ">: " + String.valueOf(path);
}
public void moveJoinsToParent() {
@ -2937,25 +2932,24 @@ public class SelectImpl
return;
}
Object aliases[] = _sel._aliases.values().toArray();
Integer aliases[] = _sel._aliases.values().toArray(new Integer[_sel._aliases.size()]);
boolean found1 = false;
boolean found2 = false;
for (int i = 0; i < aliases.length; i++) {
int alias = ((Integer)aliases[i]).intValue();
int alias = aliases[i].intValue();
if (alias == j.getIndex1())
found1 = true;
if (alias == j.getIndex2())
found2 = true;
}
if (found1 && found2)
if (found1 && found2) {
return;
else if (!found1 && !found2) {
} else if (!found1 && !found2) {
j.setIsNotMyJoin();
return;
}
else {
} else {
j.setCorrelated();
}
}
@ -2965,8 +2959,8 @@ public class SelectImpl
return;
Join j = null;
List<Join> removed = new ArrayList<Join>(5);
for (Iterator itr = _joins.iterator(); itr.hasNext();) {
j = (Join) itr.next();
for (Iterator<Join> itr = _joins.iterator(); itr.hasNext();) {
j = itr.next();
if (j.isNotMyJoin()) {
addJoinsToParent(_sel._parent, j);
removed.add(j);
@ -3035,12 +3029,12 @@ public class SelectImpl
* the alias of each selected id.
*/
protected static class Selects
extends AbstractList {
extends AbstractList<Object> {
protected List _ids = null;
protected List _idents = null;
protected Map _aliases = null;
protected Map _selectAs = null;
protected List<Object> _ids = null;
protected List<Object> _idents = null;
protected Map<Object,Object> _aliases = null;
protected Map<Object,String> _selectAs = null;
protected DBDictionary _dict = null;
/**
@ -3048,22 +3042,22 @@ public class SelectImpl
*/
public void addAll(Selects sels) {
if (_ids == null && sels._ids != null)
_ids = new ArrayList(sels._ids);
_ids = new ArrayList<Object>(sels._ids);
else if (sels._ids != null)
_ids.addAll(sels._ids);
if (_idents == null && sels._idents != null)
_idents = new ArrayList(sels._idents);
_idents = new ArrayList<Object>(sels._idents);
else if (sels._idents != null)
_idents.addAll(sels._idents);
if (_aliases == null && sels._aliases != null)
_aliases = new HashMap(sels._aliases);
_aliases = new HashMap<Object,Object>(sels._aliases);
else if (sels._aliases != null)
_aliases.putAll(sels._aliases);
if (_selectAs == null && sels._selectAs != null)
_selectAs = new HashMap(sels._selectAs);
_selectAs = new HashMap<Object,String>(sels._selectAs);
else if (sels._selectAs != null)
_selectAs.putAll(sels._selectAs);
}
@ -3080,8 +3074,8 @@ public class SelectImpl
*/
public int setAlias(Object id, Object alias, boolean ident) {
if (_ids == null) {
_ids = new ArrayList();
_aliases = new HashMap();
_ids = new ArrayList<Object>();
_aliases = new HashMap<Object,Object>();
}
int idx;
@ -3093,7 +3087,7 @@ public class SelectImpl
if (ident) {
if (_idents == null)
_idents = new ArrayList(3);
_idents = new ArrayList<Object>(3);
_idents.add(id);
}
}
@ -3136,11 +3130,11 @@ public class SelectImpl
* A list representation of the aliases, in select order, with
* AS aliases present.
*/
public List getAliases(final boolean ident, final boolean inner) {
public List<Object> getAliases(final boolean ident, final boolean inner) {
if (_ids == null)
return Collections.EMPTY_LIST;
return Collections.emptyList();
return new AbstractList() {
return new AbstractList<Object>() {
public int size() {
return (ident && _idents != null) ? _idents.size()
: _ids.size();
@ -3181,7 +3175,7 @@ public class SelectImpl
*/
public void setSelectAs(Object id, String as) {
if (_selectAs == null)
_selectAs = new HashMap((int) (5 * 1.33 + 1));
_selectAs = new HashMap<Object,String>((int) (5 * 1.33 + 1));
_selectAs.put(id, as);
}
@ -3193,7 +3187,7 @@ public class SelectImpl
return;
Object id;
for (Iterator itr = _ids.iterator(); itr.hasNext();) {
for (Iterator<Object> itr = _ids.iterator(); itr.hasNext();) {
id = itr.next();
if (id instanceof Placeholder) {
itr.remove();
@ -3242,6 +3236,30 @@ public class SelectImpl
public void moveJoinsToParent() {
}
/**
* Affirms if this instance is (structurally) immutable.
*/
public boolean isReadOnly() {
return _readOnly;
}
/**
* Marks this instance immutable.
*/
private void makeReadOnly() {
_readOnly = true;
}
/**
* Raises illegal state exception if this instance is immutable.
*/
public void assertMutable() {
if (_readOnly) {
throw new IllegalStateException("Select@" + Integer.toHexString(System.identityHashCode(this)) +
" is read-only");
}
}
}
/**
@ -3283,11 +3301,8 @@ interface PathJoins
public void nullJoins();
/**
* The select owner of this join
* @return
* Gets the select who owns this join.
*/
public Select getSelect();
public String getPathStr();
}