Mapping for a single-valued relation to another entity.
| Method from org.apache.openjpa.jdbc.meta.strats.RelationFieldStrategy Detail: |
public void appendIsNotNull(SQLBuffer sql,
Select sel,
Joins joins) {
// if no inverse, just join to mapping's table (usually a no-op
// because it'll be in the primary table) and see if fk cols aren't
// null; if inverse, then we have to do a sub-select to see if any
// inverse objects point back to this field's owner
if (field.getJoinDirection() != field.JOIN_INVERSE) {
//### probably need some sort of subselect here on fk constants
joins = join(joins, false);
Column[] cols = field.getColumns();
if (cols.length == 0)
sql.append("1 = 1");
else
sql.append(sel.getColumnAlias(cols[0], joins)).
append(" IS NOT ").appendValue(null, cols[0]);
} else
testInverseNull(sql, sel, joins, false);
}
|
public void appendIsNull(SQLBuffer sql,
Select sel,
Joins joins) {
// if no inverse, just join to mapping's table (usually a no-op
// because it'll be in the primary table) and see if fk cols are null;
// if inverse, then we have to do a sub-select to see if any inverse
// objects point back to this field's owner
if (field.getJoinDirection() != field.JOIN_INVERSE) {
//### probably need some sort of subselect here on fk constants
joins = join(joins, false);
Column[] cols = field.getColumns();
if (cols.length == 0)
sql.append("1 < > 1");
else
sql.append(sel.getColumnAlias(cols[0], joins)).
append(" IS ").appendValue(null, cols[0]);
} else
testInverseNull(sql, sel, joins, true);
}
|
public void delete(OpenJPAStateManager sm,
JDBCStore store,
RowManager rm) throws SQLException {
if (field.getMappedBy() != null)
return;
if (field.getJoinDirection() == field.JOIN_INVERSE) {
if (sm.getLoaded().get(field.getIndex())) {
OpenJPAStateManager rel = RelationStrategies.getStateManager(sm.
fetchObjectField(field.getIndex()), store.getContext());
updateInverse(sm, rel, store, rm);
} else
nullInverse(sm, rm);
} else {
field.deleteRow(sm, store, rm);
// if our foreign key has a delete action, we need to set the
// related object so constraints can be evaluated
OpenJPAStateManager rel = RelationStrategies.getStateManager
(sm.fetchObjectField(field.getIndex()), store.getContext());
if (rel != null) {
ForeignKey fk = field.getForeignKey((ClassMapping)
rel.getMetaData());
if (fk.getDeleteAction() == ForeignKey.ACTION_RESTRICT) {
Row row = field.getRow(sm, store, rm, Row.ACTION_DELETE);
row.setForeignKey(fk, null, rel);
}
}
}
}
|
public ColumnIO getColumnIO() {
return field.getColumnIO();
}
|
public Column[] getColumns() {
return field.getColumns();
}
|
public int getFieldIndex() {
return field.getIndex();
}
|
public Object getJoinValue(Object fieldVal,
Column col,
JDBCStore store) {
Object o = field.getForeignKey().getConstant(col);
if (o != null)
return o;
col = field.getForeignKey().getPrimaryKeyColumn(col);
if (col == null)
throw new InternalException();
ClassMapping relmapping = field.getTypeMapping();
Joinable j = field.getTypeMapping().assertJoinable(col);
if (ImplHelper.isManageable(fieldVal))
fieldVal = store.getContext().getObjectId(fieldVal);
if (fieldVal instanceof OpenJPAId)
fieldVal = ((OpenJPAId) fieldVal).getIdObject();
else if (relmapping.getObjectIdType() != null
&& relmapping.getObjectIdType().isInstance(fieldVal)) {
Object[] pks = ApplicationIds.toPKValues(fieldVal, relmapping);
fieldVal = pks[relmapping.getField(j.getFieldIndex()).
getPrimaryKeyIndex()];
}
return j.getJoinValue(fieldVal, col, store);
}
|
public Object getJoinValue(OpenJPAStateManager sm,
Column col,
JDBCStore store) {
return getJoinValue(sm.fetch(field.getIndex()), col, store);
}
|
public Object getPrimaryKeyValue(Result res,
Column[] cols,
ForeignKey fk,
JDBCStore store,
Joins joins) throws SQLException {
ClassMapping relmapping = field.getTypeMapping();
if (relmapping.getIdentityType() == ClassMapping.ID_DATASTORE) {
Column col = cols[0];
if (fk != null)
col = fk.getColumn(col);
long id = res.getLong(col, joins);
if (field.getObjectIdFieldTypeCode() == JavaTypes.LONG)
return Numbers.valueOf(id);
return store.newDataStoreId(id, relmapping, field.getPolymorphic()
!= ValueMapping.POLY_FALSE);
}
if (relmapping.isOpenJPAIdentity())
return ((Joinable) relmapping.getPrimaryKeyFieldMappings()[0].
getStrategy()).getPrimaryKeyValue(res, cols, fk, store, joins);
if (cols == getColumns() && fk == null)
fk = field.getForeignKey();
else
fk = createTranslatingForeignKey(relmapping, cols, fk);
return relmapping.getObjectId(store, res, fk,
field.getPolymorphic() != ValueMapping.POLY_FALSE, joins);
}
|
public Object[] getResultArguments() {
return null;
}
|
public void initialize() {
field.setUsesIntermediate(true);
ForeignKey fk = field.getForeignKey();
if (fk == null)
_fkOid = Boolean.TRUE;
else if (field.getJoinDirection() != FieldMapping.JOIN_INVERSE)
_fkOid = field.getTypeMapping().isForeignKeyObjectId(fk);
}
|
public void insert(OpenJPAStateManager sm,
JDBCStore store,
RowManager rm) throws SQLException {
if (field.getMappedBy() != null)
return;
OpenJPAStateManager rel = RelationStrategies.getStateManager
(sm.fetchObjectField(field.getIndex()), store.getContext());
if (field.getJoinDirection() == field.JOIN_INVERSE)
updateInverse(sm, rel, store, rm);
else {
Row row = field.getRow(sm, store, rm, Row.ACTION_INSERT);
if (row != null)
field.setForeignKey(row, rel);
}
}
|
public Joins join(Joins joins,
boolean forceOuter) {
// if we're not in an inverse object table join normally, otherwise
// already traversed the relation; just join back to owner table
if (field.getJoinDirection() != field.JOIN_INVERSE)
return field.join(joins, forceOuter, false);
ClassMapping[] clss = field.getIndependentTypeMappings();
if (clss.length != 1)
throw RelationStrategies.uninversable(field);
if (forceOuter)
return joins.outerJoinRelation(field.getName(),
field.getForeignKey(), clss[0], field.getSelectSubclasses(),
true, false);
return joins.joinRelation(field.getName(), field.getForeignKey(),
clss[0], field.getSelectSubclasses(), true, false);
}
|
public Joins joinRelation(Joins joins,
boolean forceOuter,
boolean traverse) {
// if this is an inverse mapping it's already joined to the relation
if (field.getJoinDirection() == field.JOIN_INVERSE)
return joins;
ClassMapping[] clss = field.getIndependentTypeMappings();
if (clss.length != 1) {
if (traverse)
throw RelationStrategies.unjoinable(field);
return joins;
}
joins = setEmbeddedVariable(joins);
if (forceOuter)
return joins.outerJoinRelation(field.getName(),
field.getForeignKey(clss[0]), clss[0],
field.getSelectSubclasses(), false, false);
return joins.joinRelation(field.getName(), field.getForeignKey(clss[0]),
clss[0], field.getSelectSubclasses(), false, false);
}
|
public void load(OpenJPAStateManager sm,
JDBCStore store,
JDBCFetchConfiguration fetch) throws SQLException {
// check for cached oid value, or load oid if no way to join
if (Boolean.TRUE.equals(_fkOid)) {
Object oid = sm.getIntermediate(field.getIndex());
if (oid != null) {
Object val = store.find(oid, field, fetch);
sm.storeObject(field.getIndex(), val);
return;
}
}
final ClassMapping[] rels = field.getIndependentTypeMappings();
final int subs = field.getSelectSubclasses();
final Joins[] resJoins = new Joins[rels.length];
// select related mapping columns; joining from the related type
// back to our fk table if not an inverse mapping (in which case we
// can just make sure the inverse cols == our pk values)
Union union = store.getSQLFactory().newUnion(rels.length);
union.setExpectedResultCount(1, false);
if (fetch.getSubclassFetchMode(field.getTypeMapping())
!= JDBCFetchConfiguration.EAGER_JOIN)
union.abortUnion();
union.select(new Union.Selector() {
public void select(Select sel, int idx) {
if (field.getJoinDirection() == field.JOIN_INVERSE)
sel.whereForeignKey(field.getForeignKey(rels[idx]),
sm.getObjectId(), field.getDefiningMapping(), store);
else {
resJoins[idx] = sel.newJoins().joinRelation(field.getName(),
field.getForeignKey(rels[idx]), rels[idx],
field.getSelectSubclasses(), false, false);
field.wherePrimaryKey(sel, sm, store);
}
sel.select(rels[idx], subs, store, fetch, fetch.EAGER_JOIN,
resJoins[idx]);
}
});
Result res = union.execute(store, fetch);
try {
Object val = null;
if (res.next())
val = res.load(rels[res.indexOf()], store, fetch,
resJoins[res.indexOf()]);
sm.storeObject(field.getIndex(), val);
} finally {
res.close();
}
}
|
public void load(OpenJPAStateManager sm,
JDBCStore store,
JDBCFetchConfiguration fetch,
Result res) throws SQLException {
if (field.getJoinDirection() == field.JOIN_INVERSE)
return;
// cached oid?
if (sm != null && sm.getIntermediate(field.getIndex()) != null)
return;
if (!Boolean.TRUE.equals(_fkOid))
return;
if (!res.containsAll(field.getColumns()))
return;
// get the related object's oid
ClassMapping relMapping = field.getTypeMapping();
Object oid = null;
if (relMapping.isMapped()) {
oid = relMapping.getObjectId(store, res, field.getForeignKey(),
field.getPolymorphic() != ValueMapping.POLY_FALSE, null);
} else {
Column[] cols = field.getColumns();
if (relMapping.getIdentityType() == ClassMapping.ID_DATASTORE) {
long id = res.getLong(cols[0]);
if (!res.wasNull())
oid = store.newDataStoreId(id, relMapping, true);
} else {
// application id
if (cols.length == 1) {
Object val = res.getObject(cols[0], null, null);
if (val != null)
oid = ApplicationIds.fromPKValues(new Object[]{ val },
relMapping);
} else {
Object[] vals = new Object[cols.length];
for (int i = 0; i < cols.length; i++) {
vals[i] = res.getObject(cols[i], null, null);
if (vals[i] == null)
break;
if (i == cols.length - 1)
oid = ApplicationIds.fromPKValues(vals, relMapping);
}
}
}
}
if (oid == null)
sm.storeObject(field.getIndex(), null);
else
sm.setIntermediate(field.getIndex(), oid);
}
|
public void loadEagerJoin(OpenJPAStateManager sm,
JDBCStore store,
JDBCFetchConfiguration fetch,
Result res) throws SQLException {
ClassMapping cls = field.getIndependentTypeMappings()[0];
sm.storeObject(field.getIndex(), res.load(cls, store, fetch,
eagerJoin(res.newJoins(), cls, false)));
}
|
public Object loadEagerParallel(OpenJPAStateManager sm,
JDBCStore store,
JDBCFetchConfiguration fetch,
Object res) throws SQLException {
// process batched results if we haven't already
Map rels;
if (res instanceof Result)
rels = processEagerParallelResult(sm, store, fetch, (Result) res);
else
rels = (Map) res;
// store object for this oid in instance
sm.storeObject(field.getIndex(), rels.remove(sm.getObjectId()));
return rels;
}
|
public void loadEmbedded(OpenJPAStateManager sm,
JDBCStore store,
JDBCFetchConfiguration fetch,
Object val) throws SQLException {
ClassMapping relMapping = field.getTypeMapping();
Object oid;
if (val == null)
oid = null;
else if (relMapping.getIdentityType() == ClassMapping.ID_DATASTORE)
oid = store.newDataStoreId(((Number) val).longValue(), relMapping,
field.getPolymorphic() != ValueMapping.POLY_FALSE);
else {
Object[] pks = (getColumns().length == 1) ? new Object[]{ val }
: (Object[]) val;
boolean nulls = true;
for (int i = 0; nulls && i < pks.length; i++)
nulls = pks[i] == null;
if (nulls)
oid = null;
else {
oid = ApplicationIds.fromPKValues(pks, relMapping);
if (field.getPolymorphic() == ValueMapping.POLY_FALSE
&& oid instanceof OpenJPAId) {
((OpenJPAId) oid).setManagedInstanceType(relMapping.
getDescribedType());
}
}
}
if (oid == null)
sm.storeObject(field.getIndex(), null);
else
sm.setIntermediate(field.getIndex(), oid);
}
|
public void map(boolean adapt) {
if (field.getTypeCode() != JavaTypes.PC || field.isEmbeddedPC())
throw new MetaDataException(_loc.get("not-relation", field));
field.getKeyMapping().getValueInfo().assertNoSchemaComponents
(field.getKey(), !adapt);
field.getElementMapping().getValueInfo().assertNoSchemaComponents
(field.getElement(), !adapt);
boolean criteria = field.getValueInfo().getUseClassCriteria();
// check for named inverse
FieldMapping mapped = field.getMappedByMapping();
if (mapped != null) {
field.getMappingInfo().assertNoSchemaComponents(field, !adapt);
field.getValueInfo().assertNoSchemaComponents(field, !adapt);
mapped.resolve(mapped.MODE_META | mapped.MODE_MAPPING);
if (!mapped.isMapped() || mapped.isSerialized())
throw new MetaDataException(_loc.get("mapped-by-unmapped",
field, mapped));
if (mapped.getTypeCode() == JavaTypes.PC) {
if (mapped.getJoinDirection() == mapped.JOIN_FORWARD) {
field.setJoinDirection(field.JOIN_INVERSE);
field.setColumns(mapped.getDefiningMapping().
getPrimaryKeyColumns());
} else if (isTypeUnjoinedSubclass(mapped))
throw new MetaDataException(_loc.get
("mapped-inverse-unjoined", field.getName(),
field.getDefiningMapping(), mapped));
field.setForeignKey(mapped.getForeignKey
(field.getDefiningMapping()));
} else if (mapped.getElement().getTypeCode() == JavaTypes.PC) {
if (isTypeUnjoinedSubclass(mapped.getElementMapping()))
throw new MetaDataException(_loc.get
("mapped-inverse-unjoined", field.getName(),
field.getDefiningMapping(), mapped));
// warn the user about making the collection side the owner
Log log = field.getRepository().getLog();
if (log.isInfoEnabled())
log.info(_loc.get("coll-owner", field, mapped));
field.setForeignKey(mapped.getElementMapping().
getForeignKey());
} else
throw new MetaDataException(_loc.get("not-inv-relation",
field, mapped));
field.setUseClassCriteria(criteria);
return;
}
// this is necessary to support openjpa 3 mappings, which didn't
// differentiate between secondary table joins and relations built
// around an inverse key: check to see if we're mapped as a secondary
// table join but we're in the table of the related type, and if so
// switch our join mapping info to our value mapping info
String tableName = field.getMappingInfo().getTableName();
Table table = field.getTypeMapping().getTable();
ValueMappingInfo vinfo = field.getValueInfo();
if (tableName != null && table != null
&& (tableName.equalsIgnoreCase(table.getName())
|| tableName.equalsIgnoreCase(table.getFullName()))) {
vinfo.setJoinDirection(MappingInfo.JOIN_INVERSE);
vinfo.setColumns(field.getMappingInfo().getColumns());
field.getMappingInfo().setTableName(null);
field.getMappingInfo().setColumns(null);
}
field.mapJoin(adapt, false);
if (field.getTypeMapping().isMapped()) {
ForeignKey fk = vinfo.getTypeJoin(field, field.getName(), true,
adapt);
field.setForeignKey(fk);
field.setColumnIO(vinfo.getColumnIO());
if (vinfo.getJoinDirection() == vinfo.JOIN_INVERSE)
field.setJoinDirection(field.JOIN_INVERSE);
} else
RelationStrategies.mapRelationToUnmappedPC(field, field.getName(),
adapt);
field.setUseClassCriteria(criteria);
field.mapPrimaryKey(adapt);
PrimaryKey pk = field.getTable().getPrimaryKey();
if (field.isPrimaryKey()) {
Column[] cols = field.getColumns();
if (pk != null && (adapt || pk.isLogical()))
for (int i = 0; i < cols.length; i++)
pk.addColumn(cols[i]);
for (int i = 0; i < cols.length; i++)
field.getDefiningMapping().setJoinable(cols[i], this);
}
// map constraints after pk so we don't re-index / re-unique pk col
field.mapConstraints(field.getName(), adapt);
}
|
public int select(Select sel,
OpenJPAStateManager sm,
JDBCStore store,
JDBCFetchConfiguration fetch,
int eagerMode) {
if (field.getJoinDirection() == field.JOIN_INVERSE)
return -1;
// already cached oid?
if (sm != null && sm.getIntermediate(field.getIndex()) != null)
return -1;
if (!Boolean.TRUE.equals(_fkOid))
return -1;
sel.select(field.getColumns(), field.join(sel));
return 0;
}
|
public void selectEagerJoin(Select sel,
OpenJPAStateManager sm,
JDBCStore store,
JDBCFetchConfiguration fetch,
int eagerMode) {
// limit the eager mode to single on recursive eager fetching b/c
// at this point the select has been modified and an attempt to
// clone it for a to-many eager select can result in a clone that
// produces invalid SQL
ClassMapping cls = field.getIndependentTypeMappings()[0];
boolean forceInner = fetch.hasFetchInnerJoin(field.getFullName(false)) ?
true : false;
sel.select(cls, field.getSelectSubclasses(), store, fetch,
JDBCFetchConfiguration.EAGER_JOIN,
eagerJoin(sel.newJoins(), cls, forceInner));
}
|
public void selectEagerParallel(SelectExecutor sel,
OpenJPAStateManager sm,
JDBCStore store,
JDBCFetchConfiguration fetch,
int eagerMode) {
final ClassMapping[] clss = field.getIndependentTypeMappings();
if (!(sel instanceof Union))
selectEagerParallel((Select) sel, clss[0], store, fetch, eagerMode);
else {
Union union = (Union) sel;
if (fetch.getSubclassFetchMode (field.getTypeMapping())
!= JDBCFetchConfiguration.EAGER_JOIN)
union.abortUnion();
union.select(new Union.Selector() {
public void select(Select sel, int idx) {
selectEagerParallel(sel, clss[idx], store, fetch,
eagerMode);
}
});
}
}
|
public void setAutoAssignedValue(OpenJPAStateManager sm,
JDBCStore store,
Column col,
Object autoInc) {
throw new UnsupportedException();
}
|
public int supportsSelect(Select sel,
int type,
OpenJPAStateManager sm,
JDBCStore store,
JDBCFetchConfiguration fetch) {
if (type == Select.TYPE_JOINLESS)
return (field.getJoinDirection() != field.JOIN_INVERSE
&& sel.isSelected(field.getTable())) ? 1 : 0;
if (type == Select.TYPE_TWO_PART)
return 1;
// already cached?
if (sm != null) {
Object oid = sm.getIntermediate(field.getIndex());
if (store.getContext().findCached(oid, null) != null)
return 0;
}
ClassMapping[] clss = field.getIndependentTypeMappings();
switch (type) {
case Select.EAGER_PARALLEL:
return clss.length;
case Select.EAGER_OUTER:
return (clss.length == 1 && store.getDBDictionary().canOuterJoin
(sel.getJoinSyntax(), field.getForeignKey(clss[0]))) ? 1 :
0;
case Select.EAGER_INNER:
return (clss.length == 1) ? 1 : 0;
default:
return 0;
}
}
|
public Object toDataStoreValue(Object val,
JDBCStore store) {
return RelationStrategies.toDataStoreValue(field, val, store);
}
|
public Object toEmbeddedDataStoreValue(Object val,
JDBCStore store) {
return toDataStoreValue(val, store);
}
|
public Object toEmbeddedObjectValue(Object val) {
return UNSUPPORTED;
}
|
public void update(OpenJPAStateManager sm,
JDBCStore store,
RowManager rm) throws SQLException {
if (field.getMappedBy() != null)
return;
OpenJPAStateManager rel = RelationStrategies.getStateManager
(sm.fetchObjectField(field.getIndex()), store.getContext());
if (field.getJoinDirection() == field.JOIN_INVERSE) {
nullInverse(sm, rm);
updateInverse(sm, rel, store, rm);
} else {
Row row = field.getRow(sm, store, rm, Row.ACTION_UPDATE);
if (row != null)
field.setForeignKey(row, rel);
}
}
|