At http://bazaar.launchpad.net/~ndb-connectors/ndb-connectors/ndbjmerge
------------------------------------------------------------
revno: 177
revision-id: mtaylor@stripped
parent: mtaylor@stripped
committer: Monty Taylor <mtaylor@stripped>
branch nick: ndbjmerge
timestamp: Thu 2007-10-11 00:49:35 -0700
message:
Added missing file to version control. Sorry guys. :)
added:
java/com/mysql/cluster/ndbj/NdbOperationResultsImpl.java
ndboperationresultsi-20071011074824-qn692jc6vcd81pxb-1
modified:
java/testsuite/ndbj/NdbIndexScanOperationUtf8Latin1Test.java
ndbindexscanoperatio-20070517181935-98huwjarzuh25b30-51
=== added file 'java/com/mysql/cluster/ndbj/NdbOperationResultsImpl.java'
--- a/java/com/mysql/cluster/ndbj/NdbOperationResultsImpl.java 1970-01-01 00:00:00 +0000
+++ b/java/com/mysql/cluster/ndbj/NdbOperationResultsImpl.java 2007-10-11 07:49:35 +0000
@@ -0,0 +1,79 @@
+package com.mysql.cluster.ndbj;
+
+import java.util.Map;
+import java.util.HashMap;
+
+public class NdbOperationResultsImpl implements NdbOperationResults {
+
+
+ protected Map<String,NdbRecAttr> resultSet;
+ protected Map<String,NdbBlob> blobResultSet;
+
+ protected NdbRecAttr realGetValue(long columnId) throws NdbApiException {
+ throw new RuntimeException("undefined class");
+ }
+ protected NdbRecAttr realGetValue(String columnName) throws NdbApiException {
+ throw new RuntimeException("undefined class");
+ }
+
+ public NdbBlob getBlobHandle(long columnId)
+ throws NdbApiException {
+ throw new RuntimeException("undefined class");
+ }
+
+ public NdbBlob getBlobHandle(String columnName)
+ throws NdbApiException{
+ throw new RuntimeException("undefined class");
+ }
+
+ public NdbOperationResultsImpl() {
+ super();
+ resultSet = new HashMap<String, NdbRecAttr>();
+ blobResultSet = new HashMap<String,NdbBlob>();
+ }
+ public void getValue(long columnId) throws NdbApiException {
+
+ Long id = columnId-1;
+ NdbRecAttr attr = realGetValue(columnId);
+ resultSet.put(id.toString(), attr);
+ }
+
+ /* (non-Javadoc)
+ * @see com.mysql.cluster.ndbj.NdbOperation#getValue(java.lang.String)
+ */
+ public void getValue(String columnName) throws NdbApiException {
+
+ NdbRecAttr attr = realGetValue(columnName);
+ resultSet.put(columnName, attr);
+ }
+
+ public NdbResultSet resultData() {
+ // TODO Auto-generated method stub
+ return NdbFactory.createNdbResultSet((NdbBaseOperation)this, resultSet);
+ }
+ public void getBlob(long columnId) throws NdbApiException {
+
+ Long id = columnId;
+ NdbBlob theBlob = getBlobHandle(columnId);
+ blobResultSet.put(id.toString(),theBlob);
+ }
+ public void getBlob(String columnName) throws NdbApiException {
+
+ NdbBlob theBlob = getBlobHandle(columnName);
+ blobResultSet.put(columnName,theBlob);
+ }
+ public void getBlob(long columnId, int length) throws NdbApiException {
+
+ Long id = columnId;
+ NdbBlob theBlob = getBlobHandle(columnId);
+ theBlob.getValue(length);
+ blobResultSet.put(id.toString(),theBlob);
+ }
+ public void getBlob(String columnName, int length) throws NdbApiException {
+
+ NdbBlob theBlob = getBlobHandle(columnName);
+ theBlob.getValue(length);
+ blobResultSet.put(columnName,theBlob);
+ }
+
+}
=== modified file 'java/testsuite/ndbj/NdbIndexScanOperationUtf8Latin1Test.java'
--- a/java/testsuite/ndbj/NdbIndexScanOperationUtf8Latin1Test.java 2007-10-11 07:35:31
+0000
+++ b/java/testsuite/ndbj/NdbIndexScanOperationUtf8Latin1Test.java 2007-10-11 07:49:35
+0000
@@ -229,7 +229,7 @@
while (rs.next(true)) {
do {
NdbOperation pkOp = rs.updateRow();
- pkOp.setString(col3, col3Val + "_jd"));
+ pkOp.setString(col3, col3Val + "_jd");
trans.execute(ExecType.Commit,
AbortOption.AbortOnError,
true);
| Thread |
|---|
| • Rev 177: Added missing file to version control. Sorry guys. :) in http://bazaar.launchpad.net/~ndb-connectors/ndb-connectors/ndbjmerge | Monty Taylor | 11 Oct |