return getDataControlConsumer.apply(null, arguments);
};
-
function DataControlConsumerObject() {
// constructor of DataControlConsumerObject
}
{'name': 'errorCallback', 'type': types_.FUNCTION, optional: true, nullable: true}
]);
+ // doing conversion of all elements to string
+ var ins = validator_.validateArgs([args.insertionData.columns, args.insertionData.values], [
+ {name : 'columns', type : types_.ARRAY, values : types_.STRING},
+ {name : 'values', type : types_.ARRAY, values : types_.STRING}
+ ]);
+
var nativeParam = {
'providerId': this.providerId,
'dataId': this.dataId,
'reqId': args.reqId,
- 'insertionData': insertionData
+ 'insertionData': args.insertionData
};
try {
var syncResult =
break;
}
- std::string& columnName = column.get<std::string>();
- std::string valueString = value.get<std::string>();
+ const std::string& columnName = column.get<std::string>();
+ const std::string& valueString = value.get<std::string>();
- bundle_add_str(b, columnName.c_str(), valueString.c_str());
+ int result = bundle_add_str(b, columnName.c_str(), valueString.c_str());
+ if (BUNDLE_ERROR_NONE != result) {
+ return result;
+ }
}
return ::data_control_sql_insert(handle, b, requestId);