Date: Friday, November 18, 2005 @ 17:47:51
  Author: gilles
    Path: /cvsroot/carob/carob

Modified: include/Connection.hpp (1.19 -> 1.20) src/Connection.cpp (1.22
          -> 1.23)

Renamed ExecXXXRequest to StatementExecuteXXX and StoredProcXXX to 
CallableStatementXXX
Applied protocol change: no need to send the query type anymore


------------------------+
 include/Connection.hpp |   14 ++++++++------
 src/Connection.cpp     |    7 ++-----
 2 files changed, 10 insertions(+), 11 deletions(-)


Index: carob/include/Connection.hpp
diff -u carob/include/Connection.hpp:1.19 carob/include/Connection.hpp:1.20
--- carob/include/Connection.hpp:1.19   Tue Nov 15 17:20:28 2005
+++ carob/include/Connection.hpp        Fri Nov 18 17:47:51 2005
@@ -25,14 +25,16 @@
 #include "CriticalSection.hpp"
 #include "DriverSocket.hpp"
 
-#define ProtocolVersion                         23
+#define ProtocolVersion                         24
 
 //#define Ping                                    -1
-#define ExecReadRequest                         0
-#define ExecWriteRequest                        1
-//#define ExecWriteRequestWithKeys                2
-//#define ExecReadStoredProcedure                 3
-//#define ExecWriteStoredProcedure                4
+#define StatementExecuteQuery                   0
+#define StatementExecuteUpdate                  1
+//#define StatementExecuteUpdateWithKeys          2
+//#define CallableStatementExecuteQuery           3
+//#define CallableStatementExecuteUpdate          4
+//#define CallableStatementExecute                5
+//#define StatementExecute                        6
 #define Begin                                   20
 #define Commit                                  21
 #define Rollback                                22
Index: carob/src/Connection.cpp
diff -u carob/src/Connection.cpp:1.22 carob/src/Connection.cpp:1.23
--- carob/src/Connection.cpp:1.22       Tue Nov 15 18:20:48 2005
+++ carob/src/Connection.cpp    Fri Nov 18 17:47:51 2005
@@ -444,7 +444,7 @@
   try
   {
     setConnectionParametersOnRequest(r);
-    *driverSocketPtr<<ExecWriteRequest;
+    *driverSocketPtr<<StatementExecuteUpdate;
     writeRequestOnStream(r);
     controllerResponse = receiveIntOrException();
   }
@@ -475,8 +475,6 @@
   if (!autoCommit)
     writeExecutedInTransaction = true;
 
-  *driverSocketPtr<<request.getType();
-
   request.sendToStream(*driverSocketPtr, controllerNeedsSqlSkeleton);
 
 }
@@ -496,8 +494,7 @@
   try
   {
     setConnectionParametersOnRequest(sr);
-    *driverSocketPtr<<ExecReadRequest;
-    *driverSocketPtr<<sr.getType();
+    *driverSocketPtr<<StatementExecuteQuery;
     sr.sendToStream(*driverSocketPtr, controllerNeedsSqlSkeleton);
     
     if (isDebugEnabled())

_______________________________________________
Carob-commits mailing list
[email protected]
https://forge.continuent.org/mailman/listinfo/carob-commits

Reply via email to