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

OPENJPA-597. Committing on behalf of Sandeep Srivastava. 

git-svn-id: https://svn.apache.org/repos/asf/openjpa/branches/1.1.x@655600 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Patrick Linskey 2008-05-12 18:58:00 +00:00
parent 51950e7d49
commit 194f59f02f
2 changed files with 38 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

39
openjpa-jdbc/src/main/java/org/apache/openjpa/jdbc/sql/DBDictionary.java
View File

@ -232,6 +232,7 @@ public class DBDictionary
public boolean supportsSelectEndIndex = false; public boolean supportsSelectEndIndex = false;
public int rangePosition = RANGE_POST_SELECT; public int rangePosition = RANGE_POST_SELECT;
public boolean requiresAliasForSubselect = false; public boolean requiresAliasForSubselect = false;
public boolean requiresTargetForDelete = false;
public boolean allowsAliasInBulkClause = true; public boolean allowsAliasInBulkClause = true;
public boolean supportsMultipleNontransactionalResultSets = true; public boolean supportsMultipleNontransactionalResultSets = true;
public String searchStringEscape = "\\"; public String searchStringEscape = "\\";
@ -1873,8 +1874,16 @@ public class DBDictionary
protected SQLBuffer toBulkOperation(ClassMapping mapping, Select sel, protected SQLBuffer toBulkOperation(ClassMapping mapping, Select sel,
JDBCStore store, Object[] params, Map updateParams) { JDBCStore store, Object[] params, Map updateParams) {
SQLBuffer sql = new SQLBuffer(this); SQLBuffer sql = new SQLBuffer(this);
if (updateParams == null) if (updateParams == null) {
if (requiresTargetForDelete) {
sql.append("DELETE ");
SQLBuffer deleteTargets = getDeleteTargets(sel);
sql.append(deleteTargets);
sql.append(" FROM ");
} else {
sql.append("DELETE FROM "); sql.append("DELETE FROM ");
}
}
else else
sql.append("UPDATE "); sql.append("UPDATE ");
sel.addJoinClassConditions(); sel.addJoinClassConditions();
@ -1970,6 +1979,28 @@ public class DBDictionary
return sql; return sql;
} }
protected SQLBuffer getDeleteTargets(Select sel) {
SQLBuffer deleteTargets = new SQLBuffer(this);
Collection aliases = sel.getTableAliases();
// Assumes aliases are of the form "TABLENAME t0"
for (Iterator itr = aliases.iterator(); itr.hasNext();) {
String tableAlias = itr.next().toString();
int spaceIndex = tableAlias.indexOf(' ');
if (spaceIndex > 0 && spaceIndex < tableAlias.length() - 1) {
if (allowsAliasInBulkClause) {
deleteTargets.append(tableAlias.substring(spaceIndex + 1));
} else {
deleteTargets.append(tableAlias.substring(0, spaceIndex));
}
} else {
deleteTargets.append(tableAlias);
}
if (itr.hasNext())
deleteTargets.append(", ");
}
return deleteTargets;
}
protected void appendUpdates(Select sel, JDBCStore store, SQLBuffer sql, protected void appendUpdates(Select sel, JDBCStore store, SQLBuffer sql,
Object[] params, Map updateParams, boolean allowAlias) { Object[] params, Map updateParams, boolean allowAlias) {
if (updateParams == null || updateParams.size() == 0) if (updateParams == null || updateParams.size() == 0)
@ -1997,7 +2028,11 @@ public class DBDictionary
Val val = (Val) next.getValue(); Val val = (Val) next.getValue();
Column col = fmd.getColumns()[0]; Column col = fmd.getColumns()[0];
sql.append(col.getName()); if (allowAlias) {
sql.append(sel.getColumnAlias(col));
} else {
sql.append(col.getName());
}
sql.append(" = "); sql.append(" = ");
ExpState state = val.initialize(sel, ctx, 0); ExpState state = val.initialize(sel, ctx, 0);

1
openjpa-jdbc/src/main/java/org/apache/openjpa/jdbc/sql/MySQLDictionary.java
View File

@ -73,6 +73,7 @@ public class MySQLDictionary
constraintNameMode = CONS_NAME_MID; constraintNameMode = CONS_NAME_MID;
supportsMultipleNontransactionalResultSets = false; supportsMultipleNontransactionalResultSets = false;
requiresAliasForSubselect = true; // new versions requiresAliasForSubselect = true; // new versions
requiresTargetForDelete = true;
supportsSelectStartIndex = true; supportsSelectStartIndex = true;
supportsSelectEndIndex = true; supportsSelectEndIndex = true;