You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@openjpa.apache.org by mi...@apache.org on 2008/12/06 00:00:22 UTC
svn commit: r723914 - in /openjpa/trunk:
openjpa-jdbc/src/main/java/org/apache/openjpa/jdbc/kernel/
openjpa-jdbc/src/main/java/org/apache/openjpa/jdbc/sql/
openjpa-persistence-jdbc/src/test/java/org/apache/openjpa/jdbc/kernel/
openjpa-persistence-jdbc/...
Author: mikedd
Date: Fri Dec 5 15:00:22 2008
New Revision: 723914
URL: http://svn.apache.org/viewvc?rev=723914&view=rev
Log:
Reverting OPENJPA_817 in trunk. Conflict with Issue 706 causes unpredictable results
Removed:
openjpa/trunk/openjpa-persistence-jdbc/src/test/java/org/apache/openjpa/jdbc/kernel/Employee.java
openjpa/trunk/openjpa-persistence-jdbc/src/test/java/org/apache/openjpa/jdbc/kernel/Story.java
openjpa/trunk/openjpa-persistence-jdbc/src/test/java/org/apache/openjpa/jdbc/kernel/Task.java
openjpa/trunk/openjpa-persistence-jdbc/src/test/java/org/apache/openjpa/jdbc/kernel/TestInsertOrder.java
Modified:
openjpa/trunk/openjpa-jdbc/src/main/java/org/apache/openjpa/jdbc/kernel/ConstraintUpdateManager.java
openjpa/trunk/openjpa-jdbc/src/main/java/org/apache/openjpa/jdbc/sql/RowManagerImpl.java
openjpa/trunk/openjpa-persistence-jdbc/src/test/java/org/apache/openjpa/persistence/test/SQLListenerTestCase.java
Modified: openjpa/trunk/openjpa-jdbc/src/main/java/org/apache/openjpa/jdbc/kernel/ConstraintUpdateManager.java
URL: http://svn.apache.org/viewvc/openjpa/trunk/openjpa-jdbc/src/main/java/org/apache/openjpa/jdbc/kernel/ConstraintUpdateManager.java?rev=723914&r1=723913&r2=723914&view=diff
==============================================================================
--- openjpa/trunk/openjpa-jdbc/src/main/java/org/apache/openjpa/jdbc/kernel/ConstraintUpdateManager.java (original)
+++ openjpa/trunk/openjpa-jdbc/src/main/java/org/apache/openjpa/jdbc/kernel/ConstraintUpdateManager.java Fri Dec 5 15:00:22 2008
@@ -58,7 +58,7 @@
(ConstraintUpdateManager.class);
public boolean orderDirty() {
- return true;
+ return false;
}
protected PreparedStatementManager newPreparedStatementManager
Modified: openjpa/trunk/openjpa-jdbc/src/main/java/org/apache/openjpa/jdbc/sql/RowManagerImpl.java
URL: http://svn.apache.org/viewvc/openjpa/trunk/openjpa-jdbc/src/main/java/org/apache/openjpa/jdbc/sql/RowManagerImpl.java?rev=723914&r1=723913&r2=723914&view=diff
==============================================================================
--- openjpa/trunk/openjpa-jdbc/src/main/java/org/apache/openjpa/jdbc/sql/RowManagerImpl.java (original)
+++ openjpa/trunk/openjpa-jdbc/src/main/java/org/apache/openjpa/jdbc/sql/RowManagerImpl.java Fri Dec 5 15:00:22 2008
@@ -22,7 +22,7 @@
import java.util.ArrayList;
import java.util.Collection;
import java.util.Collections;
-import java.util.LinkedHashMap;
+import java.util.HashMap;
import java.util.List;
import java.util.Map;
@@ -39,17 +39,17 @@
public class RowManagerImpl
implements RowManager {
- private Map<Key, PrimaryRow> _inserts = null;
- private Map<Key, PrimaryRow> _updates = null;
- private Map<Key, PrimaryRow> _deletes = null;
- private Collection<SecondaryRow> _secondaryUpdates = null;
- private Collection<SecondaryRow> _secondaryDeletes = null;
- private Collection<Row> _allRowUpdates = null;
- private Collection<Row> _allRowDeletes = null;
+ private Map _inserts = null;
+ private Map _updates = null;
+ private Map _deletes = null;
+ private Collection _secondaryUpdates = null;
+ private Collection _secondaryDeletes = null;
+ private Collection _allRowUpdates = null;
+ private Collection _allRowDeletes = null;
// we maintain a list of the order of all primary rows if the user
// wants to be able to fetch them in order
- private final List<PrimaryRow> _primaryOrder;
+ private final List _primaryOrder;
// track whether we're dealing with any auto-inc columns
private boolean _auto = false;
@@ -66,7 +66,7 @@
* @param order whether to keep track of the order in which rows are added
*/
public RowManagerImpl(boolean order) {
- _primaryOrder = (order) ? new ArrayList<PrimaryRow>() : null;
+ _primaryOrder = (order) ? new ArrayList() : null;
}
/**
@@ -80,98 +80,61 @@
* Return the ordered primary rows. Only available if ordering requested
* on construction.
*/
- public List<PrimaryRow> getOrdered() {
- if(_primaryOrder == null ) {
- return Collections.emptyList();
- }
- else {
- return _primaryOrder;
- }
+ public List getOrdered() {
+ return (_primaryOrder == null) ? Collections.EMPTY_LIST : _primaryOrder;
}
/**
* Return all inserted primary rows.
*/
- public Collection<PrimaryRow> getInserts() {
- if(_inserts == null ) {
- return Collections.emptyList();
- }
- else {
- return _inserts.values();
- }
+ public Collection getInserts() {
+ return (_inserts == null) ? Collections.EMPTY_LIST : _inserts.values();
}
/**
* Return all updated primary rows.
*/
- public Collection<PrimaryRow> getUpdates() {
- if(_updates == null ){
- return Collections.emptyList();
- }
- else {
- return _updates.values();
- }
+ public Collection getUpdates() {
+ return (_updates == null) ? Collections.EMPTY_LIST : _updates.values();
}
/**
* Return all deleted primary rows.
*/
- public Collection<PrimaryRow> getDeletes() {
- if(_deletes == null) {
- return Collections.emptyList();
- }
- else {
- return _deletes.values();
- }
+ public Collection getDeletes() {
+ return (_deletes == null) ? Collections.EMPTY_LIST : _deletes.values();
}
/**
* Return all inserted and updated secondary rows.
*/
- public Collection<SecondaryRow> getSecondaryUpdates() {
- if(_secondaryUpdates == null) {
- return Collections.emptyList();
- }
- else {
- return _secondaryUpdates;
- }
+ public Collection getSecondaryUpdates() {
+ return (_secondaryUpdates == null) ? Collections.EMPTY_LIST
+ : _secondaryUpdates;
}
/**
* Return all deleted secondary rows.
*/
- public Collection<SecondaryRow> getSecondaryDeletes() {
- if(_secondaryDeletes == null) {
- return Collections.emptyList();
- }
- else {
- return _secondaryDeletes;
- }
+ public Collection getSecondaryDeletes() {
+ return (_secondaryDeletes == null) ? Collections.EMPTY_LIST
+ : _secondaryDeletes;
}
/**
* Return any 'all row' updates.
*/
- public Collection<Row> getAllRowUpdates() {
- if(_allRowUpdates == null) {
- return Collections.emptyList();
- }
- else {
- return _allRowUpdates;
- }
+ public Collection getAllRowUpdates() {
+ return (_allRowUpdates == null) ? Collections.EMPTY_LIST
+ : _allRowUpdates;
}
/**
* Return any 'all row' deletes.
*/
- public Collection<Row> getAllRowDeletes() {
- if(_allRowDeletes == null) {
- return Collections.emptyList();
- }
- else {
- return _allRowDeletes;
- }
-
+ public Collection getAllRowDeletes() {
+ return (_allRowDeletes == null) ? Collections.EMPTY_LIST
+ : _allRowDeletes;
}
public Row getSecondaryRow(Table table, int action) {
@@ -186,12 +149,12 @@
SecondaryRow srow = (SecondaryRow) row;
if (srow.getAction() == Row.ACTION_DELETE) {
if (_secondaryDeletes == null)
- _secondaryDeletes = new ArrayList<SecondaryRow>();
- _secondaryDeletes.add((SecondaryRow) srow.clone());
+ _secondaryDeletes = new ArrayList();
+ _secondaryDeletes.add(srow.clone());
} else {
if (_secondaryUpdates == null)
- _secondaryUpdates = new ArrayList<SecondaryRow>();
- _secondaryUpdates.add((SecondaryRow) srow.clone());
+ _secondaryUpdates = new ArrayList();
+ _secondaryUpdates.add(srow.clone());
}
}
@@ -206,12 +169,12 @@
switch (row.getAction()) {
case Row.ACTION_UPDATE:
if (_allRowUpdates == null)
- _allRowUpdates = new ArrayList<Row>();
+ _allRowUpdates = new ArrayList();
_allRowUpdates.add(row);
break;
case Row.ACTION_DELETE:
if (_allRowDeletes == null)
- _allRowDeletes = new ArrayList<Row>();
+ _allRowDeletes = new ArrayList();
_allRowDeletes.add(row);
break;
default:
@@ -229,25 +192,25 @@
&& _row != null && _row.getAction() == action)
return _row;
- Map<Key, PrimaryRow> map;
+ Map map;
if (action == Row.ACTION_DELETE) {
if (_deletes == null && create)
- _deletes = new LinkedHashMap<Key, PrimaryRow>();
+ _deletes = new HashMap();
map = _deletes;
} else if (action == Row.ACTION_INSERT) {
if (_inserts == null && create)
- _inserts = new LinkedHashMap<Key, PrimaryRow>();
+ _inserts = new HashMap();
map = _inserts;
} else {
if (_updates == null && create)
- _updates = new LinkedHashMap<Key, PrimaryRow>();
+ _updates = new HashMap();
map = _updates;
}
if (map == null)
return null;
_key = new Key(table, sm);
- _row = map.get(_key);
+ _row = (PrimaryRow) map.get(_key);
if (_row == null && create) {
_row = new PrimaryRow(table, action, sm);
Modified: openjpa/trunk/openjpa-persistence-jdbc/src/test/java/org/apache/openjpa/persistence/test/SQLListenerTestCase.java
URL: http://svn.apache.org/viewvc/openjpa/trunk/openjpa-persistence-jdbc/src/test/java/org/apache/openjpa/persistence/test/SQLListenerTestCase.java?rev=723914&r1=723913&r2=723914&view=diff
==============================================================================
--- openjpa/trunk/openjpa-persistence-jdbc/src/test/java/org/apache/openjpa/persistence/test/SQLListenerTestCase.java (original)
+++ openjpa/trunk/openjpa-persistence-jdbc/src/test/java/org/apache/openjpa/persistence/test/SQLListenerTestCase.java Fri Dec 5 15:00:22 2008
@@ -21,6 +21,7 @@
import java.util.Arrays;
import java.util.List;
import java.util.ArrayList;
+import java.util.Map;
import org.apache.openjpa.lib.jdbc.AbstractJDBCListener;
import org.apache.openjpa.lib.jdbc.JDBCEvent;
@@ -33,7 +34,7 @@
*/
public abstract class SQLListenerTestCase
extends SingleEMFTestCase {
- private static String _nl = System.getProperty("line.separator");
+
protected List<String> sql = new ArrayList<String>();
protected int sqlCount;
@@ -129,28 +130,4 @@
}
}
}
-
- public void assertSQLOrder(String... expected) {
- int hits = 0;
-
- for (String executedSQL : sql) {
- if (executedSQL.matches(expected[hits])) {
- hits++;
- }
- }
-
- if (hits != expected.length) {
- StringBuilder sb = new StringBuilder();
- sb.append("Did not find SQL in expected order : ").append(_nl);
- for (String s : expected) {
- sb.append(s).append(_nl);
- }
-
- sb.append("SQL Statements issued : ");
- for (String s : sql) {
- sb.append(s).append(_nl);
- }
- fail(sb.toString());
- }
- }
}