[TIMOB-15194] Implemented Ti.Database.getRowsAffected()

src/tibb/NativeDBObject.cpp

@@ -18,7 +18,7 @@
 #pragma GCC diagnostic ignored "-Wunused-parameter"
 
 NativeDBObject::NativeDBObject(TiObject* tiObject)
-    : NativeProxyObject(tiObject) {
+    : NativeProxyObject(tiObject), rowsAffected(0) {
 }
 
 NativeDBObject::~NativeDBObject() {
@@ -75,6 +75,7 @@ int NativeDBObject::execute(NativeResultSetObject* resultSet, string command, ve
 	if (stepResult == SQLITE_DONE) {
 		sqlite3_finalize(statement);
 		resultSet->effectedRows = effectedRows;
+		rowsAffected = resultSet->effectedRows + 1;
 		resultSet->statement = statement;
 		return NATIVE_ERROR_OK;
 	}
@@ -95,6 +96,7 @@ int NativeDBObject::execute(NativeResultSetObject* resultSet, string command, ve
 	}
 
 	resultSet->effectedRows = effectedRows;
+	rowsAffected = resultSet->effectedRows;
 	sqlite3_reset(statement);
 	resultSet->stepResult = sqlite3_step(statement);
 	resultSet->statement = statement;
@@ -105,6 +107,10 @@ int NativeDBObject::execute(NativeResultSetObject* resultSet, string command, ve
 	return NATIVE_ERROR_OK;
 }
 
+int NativeDBObject::affectedRows()
+{
+	return rowsAffected;
+}
 int NativeDBObject::close() {
 
     sqlite3_close(_db);

src/tibb/NativeDBObject.h

@@ -38,7 +38,7 @@ class NativeDBObject : public NativeProxyObject
     // DB methods
     int execute(NativeResultSetObject* resultSet, string command, vector<string> bindings);
     int close();
-
+    int affectedRows();
 protected:
     virtual ~NativeDBObject();
 
@@ -49,7 +49,7 @@ class NativeDBObject : public NativeProxyObject
 
     friend class TiDBObject;
     int _open(string name);
-
+    int rowsAffected;
     sqlite3* _db;
 };
 

src/tibb/TiDBObject.cpp

@@ -12,6 +12,7 @@
 #include "TiResultSetObject.h"
 #include "TiConstants.h"
 #include "TiGenericFunctionObject.h"
+#include "TiPropertyGetObject.h"
 #include "NativeException.h"
 #include "TiMessageStrings.h"
 #include <vector>
@@ -54,6 +55,7 @@ void TiDBObject::onCreateStaticMembers() {
     TiProxy::onCreateStaticMembers();
     TiGenericFunctionObject::addGenericFunctionToParent(this, "execute", this, _execute);
     TiGenericFunctionObject::addGenericFunctionToParent(this, "close", this, _close);
+    TiPropertyGetObject::createGetProperty(this, "rowsAffected", this, _rowsAffected);
 }
 
 Handle<Value> TiDBObject::_execute(void* userContext, TiObject*, const Arguments& args)
@@ -106,6 +108,14 @@ Handle<Value> TiDBObject::_execute(void* userContext, TiObject*, const Arguments
     return Undefined();
 }
 
+Handle<Value> TiDBObject::_rowsAffected(void* userContext)
+{
+    TiDBObject* obj = (TiDBObject*) userContext;
+    NativeDBObject* ndb = (NativeDBObject*) obj->getNativeObject();
+    HandleScope scope;
+    return scope.Close(Number::New(ndb->affectedRows()));
+}
+
 Handle<Value> TiDBObject::_close(void* userContext, TiObject*, const Arguments& args)
 {
     TiDBObject* obj = (TiDBObject*) userContext;

src/tibb/TiDBObject.h

@@ -32,6 +32,7 @@ class TiDBObject : public TiProxy
 
     static Handle<Value> _execute(void* userContext, TiObject* caller, const Arguments& args);
     static Handle<Value> _close(void* userContext, TiObject* caller, const Arguments& args);
+    static Handle<Value> _rowsAffected(void* userContext);
 
 private:
     TiDBObject();