AfflictionNetworks/depot
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Use the SelectClause to obtain our types so that the main record class is

Browse Source 
always properly added. Also made SelectClause freak out if it's provided with
bogus clauses.
This commit is contained in:
Michael Bayne
2008-09-05 23:17:37 +00:00
parent 8b6f575af8
commit 263529c929
3 changed files with 12 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/java/com/samskivert/jdbc/depot/DepotRepository.java
+3 -2
View File
@@ -211,8 +211,9 @@ public abstract class DepotRepository
{ {
final List<Key<T>> keys = new ArrayList<Key<T>>(); final List<Key<T>> keys = new ArrayList<Key<T>>();
final DepotMarshaller<T> marsh = _ctx.getMarshaller(type); final DepotMarshaller<T> marsh = _ctx.getMarshaller(type);
final SQLBuilder builder = _ctx.getSQLBuilder(DepotTypes.getDepotTypes(_ctx, clauses)); SelectClause<T> select = new SelectClause<T>(type, marsh.getPrimaryKeyFields(), clauses);
builder.newQuery(new SelectClause<T>(type, marsh.getPrimaryKeyFields(), clauses)); final SQLBuilder builder = _ctx.getSQLBuilder(DepotTypes.getDepotTypes(_ctx, select));
builder.newQuery(select);
if (forUpdate) { if (forUpdate) {
_ctx.invoke(new Modifier(null) { _ctx.invoke(new Modifier(null) {
src/java/com/samskivert/jdbc/depot/FindAllQuery.java
+5 -8
View File
@@ -64,7 +64,7 @@ public abstract class FindAllQuery<T extends PersistentRecord>
if (_marsh.getComputed() != null) { if (_marsh.getComputed() != null) {
throw new IllegalArgumentException( throw new IllegalArgumentException(
"This algorithm doesn't work on @Computed records."); "This algorithm doesn't work on @Computed records.");
} }
for (QueryClause clause : clauses) { for (QueryClause clause : clauses) {
if (clause instanceof FieldOverride) { if (clause instanceof FieldOverride) {
@@ -73,10 +73,10 @@ public abstract class FindAllQuery<T extends PersistentRecord>
} }
} }
DepotTypes types = DepotTypes.getDepotTypes(ctx, clauses); SelectClause<T> select =
types.addClass(ctx, type); new SelectClause<T>(_type, _marsh.getPrimaryKeyFields(), clauses);
_builder = _ctx.getSQLBuilder(types); _builder = _ctx.getSQLBuilder(DepotTypes.getDepotTypes(ctx, select));
_clauses = clauses; _builder.newQuery(select);
} }
public List<T> invoke (Connection conn, DatabaseLiaison liaison) public List<T> invoke (Connection conn, DatabaseLiaison liaison)
@@ -86,7 +86,6 @@ public abstract class FindAllQuery<T extends PersistentRecord>
List<Key<T>> allKeys = new ArrayList<Key<T>>(); List<Key<T>> allKeys = new ArrayList<Key<T>>();
Set<Key<T>> fetchKeys = new HashSet<Key<T>>(); Set<Key<T>> fetchKeys = new HashSet<Key<T>>();
_builder.newQuery(new SelectClause<T>(_type, _marsh.getPrimaryKeyFields(), _clauses));
PreparedStatement stmt = _builder.prepare(conn); PreparedStatement stmt = _builder.prepare(conn);
try { try {
ResultSet rs = stmt.executeQuery(); ResultSet rs = stmt.executeQuery();
@@ -166,8 +165,6 @@ public abstract class FindAllQuery<T extends PersistentRecord>
JDBCUtil.close(stmt); JDBCUtil.close(stmt);
} }
} }
protected Collection<? extends QueryClause> _clauses;
} }
/** /**
src/java/com/samskivert/jdbc/depot/clause/SelectClause.java
+4
View File
@@ -99,6 +99,10 @@ public class SelectClause<T extends PersistentRecord> extends QueryClause
"Query can't contain multiple For Update clauses."); "Query can't contain multiple For Update clauses.");
} }
_forUpdate = (ForUpdate) clause; _forUpdate = (ForUpdate) clause;
} else {
throw new IllegalArgumentException(
"Unknown clause provided in select " + clause + ".");
} }
} }
} }