teiid SVN: r4606 - in branches/7.7.x/engine/src: test/java/org/teiid/query/processor and 1 other directories.
by teiid-commits＠lists.jboss.org
Author: jolee
Date: 2013-10-22 10:52:22 -0400 (Tue, 22 Oct 2013)
New Revision: 4606
Modified:
branches/7.7.x/engine/src/main/java/org/teiid/query/processor/relational/EnhancedSortMergeJoinStrategy.java
branches/7.7.x/engine/src/main/java/org/teiid/query/processor/relational/JoinNode.java
branches/7.7.x/engine/src/main/java/org/teiid/query/processor/relational/SourceState.java
branches/7.7.x/engine/src/test/java/org/teiid/query/processor/TestTextTable.java
branches/7.7.x/engine/src/test/java/org/teiid/query/processor/relational/TestJoinNode.java
Log:
TEIID-2363: (modified) backout of prefetch logic introducing Assertion error
Modified: branches/7.7.x/engine/src/main/java/org/teiid/query/processor/relational/EnhancedSortMergeJoinStrategy.java
===================================================================
--- branches/7.7.x/engine/src/main/java/org/teiid/query/processor/relational/EnhancedSortMergeJoinStrategy.java 2013-10-22 14:52:13 UTC (rev 4605)
+++ branches/7.7.x/engine/src/main/java/org/teiid/query/processor/relational/EnhancedSortMergeJoinStrategy.java 2013-10-22 14:52:22 UTC (rev 4606)
@@ -40,6 +40,7 @@
import org.teiid.logging.LogConstants;
import org.teiid.logging.LogManager;
import org.teiid.logging.MessageLevel;
+import org.teiid.query.optimizer.relational.rules.NewCalculateCostUtil;
import org.teiid.query.processor.relational.SourceState.ImplicitBuffer;
import org.teiid.query.sql.lang.JoinType;
import org.teiid.query.sql.lang.OrderBy;
@@ -235,7 +236,9 @@
}
private boolean shouldIndexIfSmall(SourceState source) throws TeiidComponentException, TeiidProcessingException {
- return source.rowCountLE(source.getSource().getBatchSize() / 2);
+ Number cardinality = source.getSource().getEstimateNodeCardinality();
+ return (source.hasBuffer() || (cardinality != null && cardinality.floatValue() != NewCalculateCostUtil.UNKNOWN_VALUE && cardinality.floatValue() <= source.getSource().getBatchSize() / 4))
+ && (source.getRowCount() <= source.getSource().getBatchSize() / 2);
}
@Override
@@ -304,26 +307,7 @@
}
private boolean shouldIndex(SourceState possibleIndex, SourceState other) throws TeiidComponentException, TeiidProcessingException {
- long size = joinNode.getBatchSize();
- int indexSize = possibleIndex.hasBuffer()?possibleIndex.getRowCount():-1;
- int otherSize = other.hasBuffer()?other.getRowCount():-1;
- //determine sizes in an incremental fashion as to avoid a full buffer of the unsorted side
- while (size < Integer.MAX_VALUE && (indexSize == -1 || otherSize == -1)) {
- if (indexSize == -1 && (possibleIndex.rowCountLE((int)size) || possibleIndex.hasBuffer())) {
- indexSize = possibleIndex.getRowCount();
- }
- if (otherSize == -1 && (other.rowCountLE((int)size) || other.hasBuffer())) {
- otherSize = other.getRowCount();
- }
- if (indexSize == -1 && otherSize != -1 && size * 4 > otherSize) {
- return false;
- }
- if (indexSize != -1 && otherSize == -1 && indexSize * 4 <= size) {
- break;
- }
- size *=2;
- }
- if ((size > Integer.MAX_VALUE && (indexSize == -1 || otherSize == -1)) || (indexSize != -1 && otherSize != -1 && indexSize * 4 > otherSize)) {
+ if (possibleIndex.getRowCount() * 4 > other.getRowCount()) {
return false; //index is too large
}
int schemaSize = this.joinNode.getBufferManager().getSchemaSize(other.getSource().getOutputElements());
Modified: branches/7.7.x/engine/src/main/java/org/teiid/query/processor/relational/JoinNode.java
===================================================================
--- branches/7.7.x/engine/src/main/java/org/teiid/query/processor/relational/JoinNode.java 2013-10-22 14:52:13 UTC (rev 4605)
+++ branches/7.7.x/engine/src/main/java/org/teiid/query/processor/relational/JoinNode.java 2013-10-22 14:52:22 UTC (rev 4606)
@@ -197,7 +197,6 @@
if (!isDependent()) {
this.joinStrategy.openRight();
this.joinStrategy.loadRight();
- this.joinStrategy.rightSource.prefetch(true);
}
throw e;
}
@@ -211,16 +210,6 @@
this.terminateBatches();
} catch (BatchAvailableException e) {
//pull the batch
- } catch (BlockedException e) {
- //TODO: this leads to duplicate exceptions, we
- //could track which side is blocking
- try {
- this.joinStrategy.leftSource.prefetch(true);
- } catch (BlockedException e1) {
-
- }
- this.joinStrategy.rightSource.prefetch(true);
- throw e;
}
return pullBatch();
}
Modified: branches/7.7.x/engine/src/main/java/org/teiid/query/processor/relational/SourceState.java
===================================================================
--- branches/7.7.x/engine/src/main/java/org/teiid/query/processor/relational/SourceState.java 2013-10-22 14:52:13 UTC (rev 4605)
+++ branches/7.7.x/engine/src/main/java/org/teiid/query/processor/relational/SourceState.java 2013-10-22 14:52:22 UTC (rev 4606)
@@ -31,6 +31,7 @@
import org.teiid.common.buffer.TupleSource;
import org.teiid.core.TeiidComponentException;
import org.teiid.core.TeiidProcessingException;
+import org.teiid.query.processor.BatchCollector;
import org.teiid.query.processor.BatchIterator;
import org.teiid.query.processor.relational.MergeJoinStrategy.SortOption;
import org.teiid.query.processor.relational.SortUtility.Mode;
@@ -45,6 +46,7 @@
private RelationalNode source;
private List expressions;
+ private BatchCollector collector;
private TupleBuffer buffer;
private List<TupleBuffer> buffers;
private List<Object> outerVals;
@@ -55,7 +57,6 @@
private boolean distinct;
private ImplicitBuffer implicitBuffer = ImplicitBuffer.FULL;
boolean open;
- private BatchIterator prefetch;
private SortUtility sortUtility;
@@ -119,107 +120,28 @@
this.iterator.closeSource();
this.iterator = null;
}
- this.prefetch = null;
this.currentTuple = null;
}
public int getRowCount() throws TeiidComponentException, TeiidProcessingException {
return this.getTupleBuffer().getRowCount();
}
-
- /**
- * Uses the prefetch logic to determine an incremental row count
- */
- public boolean rowCountLE(int count) throws TeiidComponentException, TeiidProcessingException {
- if (buffer == null) {
- prefetch(false);
- }
- while (buffer.getRowCount() <= count) {
- if (prefetch == null) {
- return true;
- }
- prefetch(false);
- }
- return false;
- }
- IndexedTupleSource getIterator() throws TeiidComponentException, TeiidProcessingException {
+ IndexedTupleSource getIterator() throws TeiidComponentException {
if (this.iterator == null) {
- if (this.buffer == null) {
- getTupleBuffer(false);
- }
- if (this.prefetch != null) {
- this.iterator = this.prefetch;
+ if (this.buffer != null) {
+ iterator = buffer.createIndexedTupleSource();
} else {
- iterator = buffer.createIndexedTupleSource(implicitBuffer == ImplicitBuffer.NONE);
+ // return a TupleBatch tuplesource iterator
+ BatchIterator bi = new BatchIterator(this.source);
+ if (implicitBuffer != ImplicitBuffer.NONE) {
+ bi.setBuffer(createSourceTupleBuffer(), implicitBuffer == ImplicitBuffer.ON_MARK);
+ }
+ this.iterator = bi;
}
}
return this.iterator;
}
-
- /**
- * Create a batch iterator to perform basic prefetching
- * @throws TeiidComponentException
- */
- private void createPrefetch() throws TeiidComponentException {
- this.prefetch = new BatchIterator(this.source);
- boolean useMark = implicitBuffer != ImplicitBuffer.FULL;
- this.buffer = createSourceTupleBuffer();
- this.prefetch.setBuffer(this.buffer, useMark);
- if (useMark) {
- this.prefetch.mark();
- }
- }
-
- /**
- * Pro-actively pull batches for later use.
- * There are unfortunately quite a few cases to cover here.
- */
- protected void prefetch(boolean limit) throws TeiidComponentException, TeiidProcessingException {
- if (!open) {
- return;
- }
- if (this.prefetch == null) {
- if (this.buffer != null) {
- return;
- }
- if (this.sortUtility != null) {
- sortUtility.sort();
- return;
- }
- if (this.source.hasFinalBuffer()) {
- this.buffer = this.source.getFinalBuffer();
- return;
- }
- createPrefetch();
- }
- if (limit && this.buffer.getManagedRowCount() >= this.source.getBatchSize() * this.source.getContext().getOptions().getJoinPrefetchBatches()) {
- return;
- }
- int curIndex = this.prefetch.getCurrentIndex();
- boolean marked = false;
- if (this.prefetch.ensureSave()) {
- marked = true;
- }
- this.prefetch.setPosition(this.buffer.getRowCount() + 1);
- BatchIterator bi = this.prefetch; //even if we clear the prefetch, we may already be using it as the iterator
- try {
- if (!this.prefetch.hasNext()) {
- this.prefetch = null;
- if (this.iterator != bi) {
- bi = null;
- }
- }
- } finally {
- if (bi != null) {
- if (marked) {
- bi.reset();
- } else {
- bi.setPosition(curIndex);
- }
- }
- }
- }
public List<Object> getOuterVals() {
return this.outerVals;
@@ -242,26 +164,14 @@
}
public TupleBuffer getTupleBuffer() throws TeiidComponentException, TeiidProcessingException {
- return getTupleBuffer(true);
- }
-
- private TupleBuffer getTupleBuffer(boolean full) throws TeiidComponentException, TeiidProcessingException {
if (this.buffer == null) {
if (this.iterator instanceof BatchIterator) {
throw new AssertionError("cannot buffer the source"); //$NON-NLS-1$
}
- if (source.hasFinalBuffer()) {
- this.buffer = source.getFinalBuffer();
- return this.buffer;
- }
- this.implicitBuffer = ImplicitBuffer.FULL;
- createPrefetch();
- }
- if (full && this.prefetch != null) {
- while (this.prefetch.hasNext()) {
- this.prefetch.setPosition(this.prefetch.getCurrentIndex() + this.source.getBatchSize());
- }
- this.prefetch = null; //fully buffered
+ if (collector == null) {
+ collector = new BatchCollector(source, source.getBufferManager(), source.getContext(), false);
+ }
+ this.buffer = collector.collectTuples();
}
return this.buffer;
}
@@ -282,13 +192,7 @@
TupleSource ts = null;
if (this.buffer != null) {
this.buffer.setForwardOnly(true);
- if (this.prefetch != null) {
- this.prefetch.setPosition(1);
- this.prefetch.disableSave();
- ts = this.prefetch;
- } else {
- ts = this.buffer.createIndexedTupleSource();
- }
+ ts = this.buffer.createIndexedTupleSource();
} else {
ts = new BatchIterator(this.source);
}
@@ -309,13 +213,12 @@
if (this.buffer != null && this.buffer != sorted) {
this.buffer.remove();
}
- this.prefetch = null;
this.buffer = sorted;
this.markDistinct(sortUtility.isDistinct());
}
public boolean hasBuffer() {
- return this.buffer != null && this.prefetch == null;
+ return this.buffer != null;
}
public boolean nextBuffer() {
@@ -325,7 +228,6 @@
}
this.buffer = this.buffers.remove(this.buffers.size() - 1);
this.buffer.setForwardOnly(false);
- this.prefetch = null;
this.resetState();
return true;
}
Modified: branches/7.7.x/engine/src/test/java/org/teiid/query/processor/TestTextTable.java
===================================================================
--- branches/7.7.x/engine/src/test/java/org/teiid/query/processor/TestTextTable.java 2013-10-22 14:52:13 UTC (rev 4605)
+++ branches/7.7.x/engine/src/test/java/org/teiid/query/processor/TestTextTable.java 2013-10-22 14:52:22 UTC (rev 4606)
@@ -285,18 +285,18 @@
@Test public void testTextTableJoin() throws Exception {
String sql = "select z.* from (select x.* from (select * from pm1.g1 where e1 = 'c') y, texttable(e1 || '\n' || e2 || '\n' || e3 COLUMNS x string) x) as z, " +
- "(select x.* from (select * from pm1.g1 where e1 = 'c') y, texttable(e1 || '\n' || e2 || '\n' || e3 COLUMNS x string) x) as z1 where z.x = z1.x";
+ "(select x.* from (select * from pm1.g1 where e1 = 'c') y, texttable(e1 || '\n' || e2 || '\n' || e3 COLUMNS x string) x) as z1 where z.x = z1.x order by z.x";
List[] expected = new List[] {
+ Arrays.asList("1"),
Arrays.asList("c"),
- Arrays.asList("1"),
Arrays.asList("true"),
};
FakeDataManager dataManager = new FakeDataManager();
sampleData1(dataManager);
RelationalPlan plan = (RelationalPlan)helpGetPlan(helpParse(sql), RealMetadataFactory.example1Cached());
- JoinNode join = (JoinNode) plan.getRootNode().getChildren()[0];
+ JoinNode join = (JoinNode) plan.getRootNode().getChildren()[0].getChildren()[0];
assertTrue(!(join.getJoinStrategy() instanceof NestedTableJoinStrategy));
helpProcess(plan, createCommandContext(), dataManager, expected);
}
Modified: branches/7.7.x/engine/src/test/java/org/teiid/query/processor/relational/TestJoinNode.java
===================================================================
--- branches/7.7.x/engine/src/test/java/org/teiid/query/processor/relational/TestJoinNode.java 2013-10-22 14:52:13 UTC (rev 4605)
+++ branches/7.7.x/engine/src/test/java/org/teiid/query/processor/relational/TestJoinNode.java 2013-10-22 14:52:22 UTC (rev 4606)
@@ -792,52 +792,6 @@
helpTestJoinDirect(expected, 40, 1);
}
- @Test public void testMergeJoinPrefetchAlreadySorted() throws Exception {
- this.joinType = JoinType.JOIN_INNER;
- int rows = 50;
- List[] data = new List[rows];
- for(int i=0; i<rows; i++) {
- data[i] = new ArrayList();
- Integer value = new Integer((i*17) % 47);
- data[i].add(value);
- }
- this.leftTuples = data;
- this.rightTuples = new List[] {
- Arrays.asList(1),
- Arrays.asList(2),
- Arrays.asList(4),
- Arrays.asList(6),
- Arrays.asList(7),
- Arrays.asList(8),
- };
- expected = new List[] {
- Arrays.asList(new Object[] { 1, 1 }),
- Arrays.asList(new Object[] { 2, 2 }),
- Arrays.asList(new Object[] { 4, 4 }),
- Arrays.asList(new Object[] { 6, 6 }),
- Arrays.asList(new Object[] { 7, 7 }),
- Arrays.asList(new Object[] { 8, 8 }),
- };
- helpCreateJoin();
- this.joinStrategy = new MergeJoinStrategy(SortOption.SORT, SortOption.ALREADY_SORTED, false);
- FakeRelationalNode newNode = new FakeRelationalNode(2, rightTuples) {
- @Override
- public TupleBatch nextBatchDirect() throws BlockedException,
- TeiidComponentException, TeiidProcessingException {
- TupleBatch tb = super.nextBatchDirect();
- if (tb.getTerminationFlag()) {
- assertFalse(leftNode.isClosed());
- }
- return tb;
- }
- };
- newNode.setElements(rightNode.getElements());
- rightNode = newNode;
-
- this.join.setJoinStrategy(joinStrategy);
- helpTestJoinDirect(expected, 5, 1);
- }
-
@Test public void testRepeatedMerge() throws Exception {
helpTestRepeatedMerge(false);
}
11 years, 4 months
teiid SVN: r4605 - in branches/7.7.x/connectors/translator-jdbc/src: main/java/org/teiid/translator/jdbc/derby and 1 other directories.
by teiid-commits＠lists.jboss.org
Author: jolee
Date: 2013-10-22 10:52:13 -0400 (Tue, 22 Oct 2013)
New Revision: 4605
Modified:
branches/7.7.x/connectors/translator-jdbc/src/main/java/org/teiid/translator/jdbc/db2/BaseDB2ExecutionFactory.java
branches/7.7.x/connectors/translator-jdbc/src/main/java/org/teiid/translator/jdbc/db2/DB2ExecutionFactory.java
branches/7.7.x/connectors/translator-jdbc/src/main/java/org/teiid/translator/jdbc/derby/DerbyExecutionFactory.java
branches/7.7.x/connectors/translator-jdbc/src/test/java/org/teiid/translator/jdbc/derby/TestDerbySQLTranslator.java
Log:
TEIID-2704: DB2 sql/xml values must be read inline
Modified: branches/7.7.x/connectors/translator-jdbc/src/main/java/org/teiid/translator/jdbc/db2/BaseDB2ExecutionFactory.java
===================================================================
--- branches/7.7.x/connectors/translator-jdbc/src/main/java/org/teiid/translator/jdbc/db2/BaseDB2ExecutionFactory.java 2013-10-22 14:52:04 UTC (rev 4604)
+++ branches/7.7.x/connectors/translator-jdbc/src/main/java/org/teiid/translator/jdbc/db2/BaseDB2ExecutionFactory.java 2013-10-22 14:52:13 UTC (rev 4605)
@@ -21,20 +21,23 @@
*/
package org.teiid.translator.jdbc.db2;
-
+
+import java.sql.CallableStatement;
+import java.sql.ResultSet;
+import java.sql.SQLException;
import java.util.Arrays;
import java.util.List;
+import org.teiid.language.Comparison.Operator;
import org.teiid.language.DerivedColumn;
import org.teiid.language.Expression;
import org.teiid.language.Function;
import org.teiid.language.Join;
+import org.teiid.language.Join.JoinType;
import org.teiid.language.LanguageFactory;
import org.teiid.language.LanguageObject;
import org.teiid.language.Limit;
import org.teiid.language.Literal;
-import org.teiid.language.Comparison.Operator;
-import org.teiid.language.Join.JoinType;
import org.teiid.translator.ExecutionContext;
import org.teiid.translator.SourceSystemFunctions;
import org.teiid.translator.TranslatorException;
@@ -178,4 +181,21 @@
return false;
}
+ @Override
+ public Object retrieveValue(ResultSet results, int columnIndex,
+ Class<?> expectedType) throws SQLException {
+ if (expectedType == TypeFacility.RUNTIME_TYPES.XML) {
+ return results.getString(columnIndex);
+ }
+ return super.retrieveValue(results, columnIndex, expectedType);
+ }
+
+ @Override
+ public Object retrieveValue(CallableStatement results, int parameterIndex,
+ Class<?> expectedType) throws SQLException {
+ if (expectedType == TypeFacility.RUNTIME_TYPES.XML) {
+ return results.getString(parameterIndex);
+ }
+ return super.retrieveValue(results, parameterIndex, expectedType);
+ }
}
Modified: branches/7.7.x/connectors/translator-jdbc/src/main/java/org/teiid/translator/jdbc/db2/DB2ExecutionFactory.java
===================================================================
--- branches/7.7.x/connectors/translator-jdbc/src/main/java/org/teiid/translator/jdbc/db2/DB2ExecutionFactory.java 2013-10-22 14:52:04 UTC (rev 4604)
+++ branches/7.7.x/connectors/translator-jdbc/src/main/java/org/teiid/translator/jdbc/db2/DB2ExecutionFactory.java 2013-10-22 14:52:13 UTC (rev 4605)
@@ -150,5 +150,4 @@
}
});
}
-
}
Modified: branches/7.7.x/connectors/translator-jdbc/src/main/java/org/teiid/translator/jdbc/derby/DerbyExecutionFactory.java
===================================================================
--- branches/7.7.x/connectors/translator-jdbc/src/main/java/org/teiid/translator/jdbc/derby/DerbyExecutionFactory.java 2013-10-22 14:52:04 UTC (rev 4604)
+++ branches/7.7.x/connectors/translator-jdbc/src/main/java/org/teiid/translator/jdbc/derby/DerbyExecutionFactory.java 2013-10-22 14:52:13 UTC (rev 4605)
@@ -23,11 +23,16 @@
package org.teiid.translator.jdbc.derby;
import java.util.ArrayList;
+import java.util.Arrays;
import java.util.List;
+import org.teiid.language.DerivedColumn;
+import org.teiid.language.LanguageObject;
+import org.teiid.translator.ExecutionContext;
import org.teiid.translator.SourceSystemFunctions;
import org.teiid.translator.Translator;
import org.teiid.translator.TranslatorException;
+import org.teiid.translator.TypeFacility;
import org.teiid.translator.jdbc.EscapeSyntaxModifier;
import org.teiid.translator.jdbc.db2.BaseDB2ExecutionFactory;
import org.teiid.translator.jdbc.oracle.LeftOrRightFunctionModifier;
@@ -184,5 +189,20 @@
public boolean supportsRowLimit() {
return this.getDatabaseVersion().compareTo(TEN_5) >= 0;
}
-
-}
+
+ @Override
+ public List<?> translate(LanguageObject obj, ExecutionContext context) {
+ if (obj instanceof DerivedColumn) {
+ DerivedColumn selectSymbol = (DerivedColumn)obj;
+
+ if (selectSymbol.getExpression().getType() == TypeFacility.RUNTIME_TYPES.XML) {
+ if (selectSymbol.getAlias() == null) {
+ return Arrays.asList("XMLSERIALIZE(", selectSymbol.getExpression(), " AS CLOB)"); //$NON-NLS-1$//$NON-NLS-2$
+ }
+ //we're assuming that alias quoting shouldn't be needed
+ return Arrays.asList("XMLSERIALIZE(", selectSymbol.getExpression(), " AS CLOB) AS ", selectSymbol.getAlias()); //$NON-NLS-1$//$NON-NLS-2$
+ }
+ }
+ return super.translate(obj, context);
+ }
+}
\ No newline at end of file
Modified: branches/7.7.x/connectors/translator-jdbc/src/test/java/org/teiid/translator/jdbc/derby/TestDerbySQLTranslator.java
===================================================================
--- branches/7.7.x/connectors/translator-jdbc/src/test/java/org/teiid/translator/jdbc/derby/TestDerbySQLTranslator.java 2013-10-22 14:52:04 UTC (rev 4604)
+++ branches/7.7.x/connectors/translator-jdbc/src/test/java/org/teiid/translator/jdbc/derby/TestDerbySQLTranslator.java 2013-10-22 14:52:13 UTC (rev 4605)
@@ -71,5 +71,4 @@
TranslationHelper.helpTestVisitor(TranslationHelper.BQT_VDB, input, output, TRANSLATOR);
}
-
}
11 years, 4 months
teiid SVN: r4604 - branches/7.7.x/engine/src/main/java/org/teiid/dqp/internal/process.
by teiid-commits＠lists.jboss.org
Author: jolee
Date: 2013-10-22 10:52:04 -0400 (Tue, 22 Oct 2013)
New Revision: 4604
Modified:
branches/7.7.x/engine/src/main/java/org/teiid/dqp/internal/process/RequestWorkItem.java
Log:
TEIID-2701: Do not proactively close source executions under a transaction scope higher than request
Modified: branches/7.7.x/engine/src/main/java/org/teiid/dqp/internal/process/RequestWorkItem.java
===================================================================
--- branches/7.7.x/engine/src/main/java/org/teiid/dqp/internal/process/RequestWorkItem.java 2013-10-11 14:21:18 UTC (rev 4603)
+++ branches/7.7.x/engine/src/main/java/org/teiid/dqp/internal/process/RequestWorkItem.java 2013-10-22 14:52:04 UTC (rev 4604)
@@ -387,19 +387,19 @@
}
}
if (this.transactionState == TransactionState.ACTIVE) {
- /*
- * TEIID-14 if we are done producing batches, then proactively close transactional
- * executions even ones that were intentionally kept alive. this may
- * break the read of a lob from a transactional source under a transaction
- * if the source does not support holding the clob open after commit
- */
- for (DataTierTupleSource connectorRequest : getConnectorRequests()) {
- if (connectorRequest.isTransactional()) {
- connectorRequest.fullyCloseSource();
- }
- }
this.transactionState = TransactionState.DONE;
if (transactionContext.getTransactionType() == TransactionContext.Scope.REQUEST) {
+ /*
+ * TEIID-14 if we are done producing batches, then proactively close transactional
+ * executions even ones that were intentionally kept alive. this may
+ * break the read of a lob from a transactional source under a transaction
+ * if the source does not support holding the clob open after commit
+ */
+ for (DataTierTupleSource connectorRequest : getConnectorRequests()) {
+ if (connectorRequest.isTransactional()) {
+ connectorRequest.fullyCloseSource();
+ }
+ }
this.transactionService.commit(transactionContext);
} else {
suspend();
11 years, 4 months
[teiid/teiid] c8837f: TEIID-2696 These changes are for the resource adap...
by vhalbert
Branch: refs/heads/master
Home: https://github.com/teiid/teiid
Commit: c8837fd2aaf7c8c1399d1e51f78cbd1eb507fa04
https://github.com/teiid/teiid/commit/c8837fd2aaf7c8c1399d1e51f78cbd1eb50...
Author: vhalbert <vhalbert(a)redhat.com>
Date: 2013-10-21 (Mon, 21 Oct 2013)
Changed paths:
R build/kits/jboss-as7/docs/teiid/datasources/file/create-ds.cli
A build/kits/jboss-as7/docs/teiid/datasources/file/create-file-ds.cli
A build/kits/jboss-as7/docs/teiid/datasources/file/create-file-ds.properties
M build/kits/jboss-as7/docs/teiid/datasources/file/readme.txt
A build/kits/jboss-as7/docs/teiid/datasources/google/create-google-ds.cli
A build/kits/jboss-as7/docs/teiid/datasources/google/create-google-ds.properties
M build/kits/jboss-as7/docs/teiid/datasources/google/readme.txt
R build/kits/jboss-as7/docs/teiid/datasources/infinispan/create-ds.cli
A build/kits/jboss-as7/docs/teiid/datasources/infinispan/create-infinispan-ds.cli
A build/kits/jboss-as7/docs/teiid/datasources/infinispan/create-infinispan-ds.properties
M build/kits/jboss-as7/docs/teiid/datasources/infinispan/readme.txt
M build/kits/jboss-as7/docs/teiid/datasources/ldap/create-ldap-ds.cli
A build/kits/jboss-as7/docs/teiid/datasources/ldap/create-ldap-ds.properties
M build/kits/jboss-as7/docs/teiid/datasources/ldap/readme.txt
M build/kits/jboss-as7/docs/teiid/datasources/mongodb/create-mongodb-ds.cli
A build/kits/jboss-as7/docs/teiid/datasources/mongodb/create-mongodb-ds.properties
M build/kits/jboss-as7/docs/teiid/datasources/mongodb/readme.txt
M build/kits/jboss-as7/docs/teiid/datasources/salesforce/create-salesforce-ds.cli
A build/kits/jboss-as7/docs/teiid/datasources/salesforce/create-salesforce-ds.properties
M build/kits/jboss-as7/docs/teiid/datasources/salesforce/readme.txt
M build/kits/jboss-as7/docs/teiid/datasources/web-service/create-ws-ds.cli
A build/kits/jboss-as7/docs/teiid/datasources/web-service/create-ws-ds.properties
M build/kits/jboss-as7/docs/teiid/datasources/web-service/readme.txt
Log Message:
-----------
TEIID-2696 These changes are for the resource adapter related datasources, to make the CLI script property driven
11 years, 4 months
[teiid/teiid] 268861: TEIID-2696 These changes are for the resource adap...
by shawkins
Branch: refs/heads/8.4.x
Home: https://github.com/teiid/teiid
Commit: 26886134ffa1e8c21c6c372542732537efca3eb6
https://github.com/teiid/teiid/commit/26886134ffa1e8c21c6c372542732537efc...
Author: vhalbert <vhalbert(a)redhat.com>
Date: 2013-10-18 (Fri, 18 Oct 2013)
Changed paths:
R build/kits/jboss-as7/docs/teiid/datasources/file/create-ds.cli
A build/kits/jboss-as7/docs/teiid/datasources/file/create-file-ds.cli
A build/kits/jboss-as7/docs/teiid/datasources/file/create-file-ds.properties
M build/kits/jboss-as7/docs/teiid/datasources/file/readme.txt
A build/kits/jboss-as7/docs/teiid/datasources/google/create-google-ds.cli
A build/kits/jboss-as7/docs/teiid/datasources/google/create-google-ds.properties
M build/kits/jboss-as7/docs/teiid/datasources/google/readme.txt
R build/kits/jboss-as7/docs/teiid/datasources/infinispan/create-ds.cli
A build/kits/jboss-as7/docs/teiid/datasources/infinispan/create-infinispan-ds.cli
A build/kits/jboss-as7/docs/teiid/datasources/infinispan/create-infinispan-ds.properties
M build/kits/jboss-as7/docs/teiid/datasources/infinispan/readme.txt
M build/kits/jboss-as7/docs/teiid/datasources/ldap/create-ldap-ds.cli
A build/kits/jboss-as7/docs/teiid/datasources/ldap/create-ldap-ds.properties
M build/kits/jboss-as7/docs/teiid/datasources/ldap/readme.txt
M build/kits/jboss-as7/docs/teiid/datasources/mongodb/create-mongodb-ds.cli
A build/kits/jboss-as7/docs/teiid/datasources/mongodb/create-mongodb-ds.properties
M build/kits/jboss-as7/docs/teiid/datasources/mongodb/readme.txt
M build/kits/jboss-as7/docs/teiid/datasources/salesforce/create-salesforce-ds.cli
A build/kits/jboss-as7/docs/teiid/datasources/salesforce/create-salesforce-ds.properties
M build/kits/jboss-as7/docs/teiid/datasources/salesforce/readme.txt
M build/kits/jboss-as7/docs/teiid/datasources/web-service/create-ws-ds.cli
A build/kits/jboss-as7/docs/teiid/datasources/web-service/create-ws-ds.properties
M build/kits/jboss-as7/docs/teiid/datasources/web-service/readme.txt
Log Message:
-----------
TEIID-2696 These changes are for the resource adapter related datasources, to make the CLI script property driven
Commit: a980ba4ba77c817056d7b7d9cb3bac7e6046aa76
https://github.com/teiid/teiid/commit/a980ba4ba77c817056d7b7d9cb3bac7e604...
Author: shawkins <shawkins(a)redhat.com>
Date: 2013-10-21 (Mon, 21 Oct 2013)
Changed paths:
R build/kits/jboss-as7/docs/teiid/datasources/file/create-ds.cli
A build/kits/jboss-as7/docs/teiid/datasources/file/create-file-ds.cli
A build/kits/jboss-as7/docs/teiid/datasources/file/create-file-ds.properties
M build/kits/jboss-as7/docs/teiid/datasources/file/readme.txt
A build/kits/jboss-as7/docs/teiid/datasources/google/create-google-ds.cli
A build/kits/jboss-as7/docs/teiid/datasources/google/create-google-ds.properties
M build/kits/jboss-as7/docs/teiid/datasources/google/readme.txt
R build/kits/jboss-as7/docs/teiid/datasources/infinispan/create-ds.cli
A build/kits/jboss-as7/docs/teiid/datasources/infinispan/create-infinispan-ds.cli
A build/kits/jboss-as7/docs/teiid/datasources/infinispan/create-infinispan-ds.properties
M build/kits/jboss-as7/docs/teiid/datasources/infinispan/readme.txt
M build/kits/jboss-as7/docs/teiid/datasources/ldap/create-ldap-ds.cli
A build/kits/jboss-as7/docs/teiid/datasources/ldap/create-ldap-ds.properties
M build/kits/jboss-as7/docs/teiid/datasources/ldap/readme.txt
M build/kits/jboss-as7/docs/teiid/datasources/mongodb/create-mongodb-ds.cli
A build/kits/jboss-as7/docs/teiid/datasources/mongodb/create-mongodb-ds.properties
M build/kits/jboss-as7/docs/teiid/datasources/mongodb/readme.txt
M build/kits/jboss-as7/docs/teiid/datasources/salesforce/create-salesforce-ds.cli
A build/kits/jboss-as7/docs/teiid/datasources/salesforce/create-salesforce-ds.properties
M build/kits/jboss-as7/docs/teiid/datasources/salesforce/readme.txt
M build/kits/jboss-as7/docs/teiid/datasources/web-service/create-ws-ds.cli
A build/kits/jboss-as7/docs/teiid/datasources/web-service/create-ws-ds.properties
M build/kits/jboss-as7/docs/teiid/datasources/web-service/readme.txt
Log Message:
-----------
Merge pull request #136 from vhalbert/teiid-2696
Teiid 2696 - changed to property drive CLI scripting of the resource adapters
Compare: https://github.com/teiid/teiid/compare/fe758d862b0f...a980ba4ba77c
11 years, 4 months
[teiid/teiid] 2433d1: [maven-release-plugin] prepare for next developmen...
by Steve Hawkins
Branch: refs/heads/master
Home: https://github.com/teiid/teiid
Commit: 2433d11f32cd444d82ccd551ada34f4bcb7f3825
https://github.com/teiid/teiid/commit/2433d11f32cd444d82ccd551ada34f4bcb7...
Author: Steve Hawkins <shawkins(a)redhat.com>
Date: 2013-10-18 (Fri, 18 Oct 2013)
Changed paths:
M admin/pom.xml
M adminshell/pom.xml
M api/pom.xml
M build/pom.xml
M client-jdk15/pom.xml
M client/pom.xml
M common-core/pom.xml
M connectors/connector-cassandra/pom.xml
M connectors/connector-file/pom.xml
M connectors/connector-google/pom.xml
M connectors/connector-infinispan/pom.xml
M connectors/connector-ldap/pom.xml
M connectors/connector-mongodb/pom.xml
M connectors/connector-salesforce/pom.xml
M connectors/connector-ws/pom.xml
M connectors/google-api/pom.xml
M connectors/mongodb-api/pom.xml
M connectors/pom.xml
M connectors/salesforce-api/pom.xml
M connectors/sandbox/pom.xml
M connectors/sandbox/translator-yahoo/pom.xml
M connectors/translator-cassandra/pom.xml
M connectors/translator-file/pom.xml
M connectors/translator-google/pom.xml
M connectors/translator-hive/pom.xml
M connectors/translator-jdbc/pom.xml
M connectors/translator-jpa/pom.xml
M connectors/translator-ldap/pom.xml
M connectors/translator-loopback/pom.xml
M connectors/translator-mongodb/pom.xml
M connectors/translator-object/pom.xml
M connectors/translator-odata/pom.xml
M connectors/translator-olap/pom.xml
M connectors/translator-salesforce/pom.xml
M connectors/translator-ws/pom.xml
M engine/pom.xml
M hibernate-dialect/pom.xml
M jboss-integration/pom.xml
M metadata/pom.xml
M odata/pom.xml
M pom.xml
M runtime/pom.xml
M test-integration/common/pom.xml
M test-integration/db/pom.xml
M test-integration/perf/pom.xml
M test-integration/pom.xml
Log Message:
-----------
[maven-release-plugin] prepare for next development iteration
11 years, 4 months
[teiid/teiid] 8ed37f: [maven-release-plugin] prepare release teiid-paren...
by Steve Hawkins
Branch: refs/heads/master
Home: https://github.com/teiid/teiid
Commit: 8ed37f15b5deb1f357570d1293fa5880e2c17baf
https://github.com/teiid/teiid/commit/8ed37f15b5deb1f357570d1293fa5880e2c...
Author: Steve Hawkins <shawkins(a)redhat.com>
Date: 2013-10-18 (Fri, 18 Oct 2013)
Changed paths:
M admin/pom.xml
M adminshell/pom.xml
M api/pom.xml
M build/pom.xml
M client-jdk15/pom.xml
M client/pom.xml
M common-core/pom.xml
M connectors/connector-cassandra/pom.xml
M connectors/connector-file/pom.xml
M connectors/connector-google/pom.xml
M connectors/connector-infinispan/pom.xml
M connectors/connector-ldap/pom.xml
M connectors/connector-mongodb/pom.xml
M connectors/connector-salesforce/pom.xml
M connectors/connector-ws/pom.xml
M connectors/google-api/pom.xml
M connectors/mongodb-api/pom.xml
M connectors/pom.xml
M connectors/salesforce-api/pom.xml
M connectors/sandbox/pom.xml
M connectors/sandbox/translator-yahoo/pom.xml
M connectors/translator-cassandra/pom.xml
M connectors/translator-file/pom.xml
M connectors/translator-google/pom.xml
M connectors/translator-hive/pom.xml
M connectors/translator-jdbc/pom.xml
M connectors/translator-jpa/pom.xml
M connectors/translator-ldap/pom.xml
M connectors/translator-loopback/pom.xml
M connectors/translator-mongodb/pom.xml
M connectors/translator-object/pom.xml
M connectors/translator-odata/pom.xml
M connectors/translator-olap/pom.xml
M connectors/translator-salesforce/pom.xml
M connectors/translator-ws/pom.xml
M engine/pom.xml
M hibernate-dialect/pom.xml
M jboss-integration/pom.xml
M metadata/pom.xml
M odata/pom.xml
M pom.xml
M runtime/pom.xml
M test-integration/common/pom.xml
M test-integration/db/pom.xml
M test-integration/perf/pom.xml
M test-integration/pom.xml
Log Message:
-----------
[maven-release-plugin] prepare release teiid-parent-8.6.0.Alpha2
11 years, 4 months