Home
last modified time | relevance | path

Searched refs:rowid (Results 1 - 19 of 19) sorted by relevance

/foundation/distributeddatamgr/relational_store/test/js/relationalstore/unittest/src/
H A DRdbStoreValueType.test.js72 let rowid = await store.insert("bigint_table", bucket);
73 console.log(TAG + "insert():=>" + rowid);
111 let rowid = await store.insert("bigint_table", bucket);
112 console.log(TAG + "insert():=>" + rowid);
/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/
H A Dtrans_db.cpp64 int64_t rowid = -1; in Insert() local
67 return { errCode, rowid }; in Insert()
71 return { errCode, rowid }; in Insert()
73 rowid = statement->Changes() > 0 ? statement->LastInsertRowId() : -1; in Insert()
74 return { errCode, rowid }; in Insert()
H A Drdb_store.cpp52 int64_t rowid = 0; in operator std::map() local
53 result_->GetLong(0, rowid); in operator std::map()
54 index = rowid; in operator std::map()
115 auto [errCode, rowid] = Insert(table, row, NO_ACTION); in Insert()
117 outRowId = rowid; in Insert()
125 auto [errCode, rowid] = Insert(table, row, resolution); in InsertWithConflictResolution()
127 outRowId = rowid; in InsertWithConflictResolution()
134 auto [errCode, rowid] = Insert(table, row, Resolution::ON_CONFLICT_REPLACE); in Replace()
136 outRowId = rowid; in Replace()
H A Drdb_store_impl.cpp977 int64_t rowid = -1; in Insert() local
978 auto errCode = ExecuteForLastInsertedRowId(rowid, sql, bindArgs); in Insert()
983 return { errCode, rowid }; in Insert()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/
H A Dsqlite_single_ver_relational_storage_executor.cpp96 LOGE("[CreateDistributedTable] Not support create distributed table without rowid."); in CheckTableConstraint()
178 std::string rowid = std::string(DBConstant::SQLITE_INNER_ROWID); in GeneLogInfoForExistedData() local
182 std::string sql = "INSERT OR REPLACE INTO " + logTable + " SELECT " + rowid + ", '', '', " + timeOffsetStr + in GeneLogInfoForExistedData()
183 " + " + rowid + ", " + timeOffsetStr + " + " + rowid + ", " + flag + ", " + calPrimaryKeyHash + ", '', " + in GeneLogInfoForExistedData()
193 std::string sql = "INSERT OR REPLACE INTO " + logTable + " SELECT " + rowid + in GeneLogInfoForExistedData()
194 ", '', '', " + timeOffsetStr + " + " + rowid + ", " + in GeneLogInfoForExistedData()
195 timeOffsetStr + " + " + rowid + ", " + flag + ", " + calPrimaryKeyHash + ", '', "; in GeneLogInfoForExistedData()
796 const DataItem &dataItem, int64_t rowid) in SaveSyncLog()
817 SQLiteUtils::BindInt64ToStatement(statement, 1, rowid); // in SaveSyncLog()
795 SaveSyncLog(sqlite3_stmt *statement, sqlite3_stmt *queryStmt, const DataItem &dataItem, int64_t rowid) SaveSyncLog() argument
862 SaveSyncDataItem(const DataItem &dataItem, SaveSyncDataStmt &saveStmt, RelationalSyncDataInserter &inserter, int64_t &rowid) SaveSyncDataItem() argument
980 int64_t rowid = -1; SaveSyncDataItem() local
[all...]
H A Dsqlite_single_ver_relational_storage_extend_executor.cpp320 int64_t rowid = data.rowid[index]; in InitFillUploadAssetStatement() local
321 return SQLiteUtils::BindInt64ToStatement(statement, dbAssets.size() + ROW_ID_INDEX, rowid); in InitFillUploadAssetStatement()
877 if (syncBatch.rowid.size() != syncBatch.timestamp.size()) { in GetReferenceGidByStmt()
878 LOGE("[RDBExecutor] rowid size [%zu] not equal to timestamp size [%zu].", syncBatch.rowid.size(), in GetReferenceGidByStmt()
883 for (size_t i = 0u; i < syncBatch.rowid.size(); i++) { in GetReferenceGidByStmt()
884 errCode = SQLiteUtils::BindInt64ToStatement(statement, 1, syncBatch.rowid[i]); // 1 is rowid index in GetReferenceGidByStmt()
886 LOGE("[RDBExecutor] bind rowid t in GetReferenceGidByStmt()
1072 BindStmtWithCloudGidInner(const std::string &gid, int64_t rowid, sqlite3_stmt *&stmt, int &fillGidCount) BindStmtWithCloudGidInner() argument
[all...]
H A Dsqlite_single_ver_relational_storage_executor_extend.cpp176 int64_t rowid = SQLiteUtils::GetLastRowId(dbHandle_); in GetPrimaryKeyHashValue() local
178 DBCommon::StringToVector(std::to_string(rowid), value); in GetPrimaryKeyHashValue()
823 int64_t rowid = SQLiteUtils::GetLastRowId(dbHandle_); in BindValueToInsertLogStatement() local
824 int errCode = SQLiteUtils::BindInt64ToStatement(insertLogStmt, 1, rowid); in BindValueToInsertLogStatement()
826 LOGE("Bind rowid to insert log statement failed, %d", errCode); in BindValueToInsertLogStatement()
873 vBucket[CloudDbConstant::ROW_ID_FIELD_NAME] = rowid; // fill rowid to cloud data to notify user in BindValueToInsertLogStatement()
1502 if (cloudDataResult.insData.extend.empty() || cloudDataResult.insData.rowid.empty() || in UpdateCloudLogGid()
1503 cloudDataResult.insData.extend.size() != cloudDataResult.insData.rowid.size()) { in UpdateCloudLogGid()
H A Dsqlite_single_ver_relational_storage_executor.h261 int64_t &rowid);
267 int SaveSyncLog(sqlite3_stmt *statement, sqlite3_stmt *queryStmt, const DataItem &dataItem, int64_t rowid);
394 int BindStmtWithCloudGidInner(const std::string &gid, int64_t rowid,
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/cloud/
H A Dcloud_storage_utils.cpp798 std::string rowid = std::string(DBConstant::SQLITE_INNER_ROWID); in GetTableRefUpdateSql() local
820 reference.sourceTableName + "." + rowid + " WHERE "; in GetTableRefUpdateSql()
868 if (data.rowid.empty() || data.timestamp.empty()) { in ChkFillCloudAssetParam()
870 LOGE("param is empty when fill cloud Asset. rowidN:%u, timeN:%u", errCode, data.rowid.size(), in ChkFillCloudAssetParam()
874 if (data.assets.size() != data.rowid.size() || data.assets.size() != data.timestamp.size() || in ChkFillCloudAssetParam()
878 "hashKeyN:%u, extendN:%u", data.assets.size(), data.rowid.size(), data.timestamp.size(), in ChkFillCloudAssetParam()
1281 int64_t *rowid = std::get_if<int64_t>(&flags[CloudDbConstant::ROWID]); in IdentifyCloudTypeInner() local
1286 if (rowid == nullptr || flag == nullptr || timeStamp == nullptr || hashKey == nullptr) { in IdentifyCloudTypeInner()
1296 cloudSyncData.lockData.rowid.push_back(*rowid); in IdentifyCloudTypeInner()
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/
H A Ddistributeddb_cloud_save_cloud_data_test.cpp1407 for (size_t i = 0u; i < batchData.rowid.size(); ++i) { in CheckCloudBatchData()
1408 int64_t rowid = batchData.rowid[i]; in CheckCloudBatchData() local
1415 EXPECT_EQ(std::to_string(rowid), entries["targetTable"]); in CheckCloudBatchData()
1433 EXPECT_EQ(syncBatch.rowid.size(), 1u); // has 1 record in HWTEST_F()
1434 for (auto rowid : syncBatch.rowid) { in HWTEST_F()
1436 entries["targetTable"] = std::to_string(rowid); in HWTEST_F()
1437 referenceGid[rowid] = entries; in HWTEST_F()
1441 syncData.insData.rowid in HWTEST_F()
[all...]
H A Ddistributeddb_cloud_interfaces_relational_sync_test.cpp295 void UpdateAssetForTest(sqlite3 *&db, AssetOpType opType, int64_t cloudCount, int64_t rowid) in UpdateAssetForTest() argument
297 string sql = "UPDATE " + g_tables[0] + " SET assert = ? where rowid = '" + std::to_string(rowid) + "';"; in UpdateAssetForTest()
301 asset.name = "Phone" + std::to_string(rowid - cloudCount - 1); in UpdateAssetForTest()
318 void UpdateAssetsForTest(sqlite3 *&db, AssetOpType opType, int64_t rowid) in UpdateAssetsForTest() argument
320 string sql = "UPDATE " + g_tables[1] + " SET asserts = ? where rowid = '" + std::to_string(rowid) + "';"; in UpdateAssetsForTest()
324 asset1.name = g_localAsset.name + std::to_string(rowid); in UpdateAssetsForTest()
326 asset2.name = g_localAsset.name + std::to_string(rowid + 1); in UpdateAssetsForTest()
360 void UpdateLocalAssets(sqlite3 *&db, Assets &assets, int64_t rowid) in UpdateLocalAssets() argument
1451 int rowid = 27; HWTEST_F() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/cloud/
H A Dcloud_db_types.h33 std::vector<int64_t> rowid; member
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/
H A Ddistributeddb_relational_cloud_syncable_storage_test.cpp334 void UpdateLocalAsset(const std::string &tableName, Asset &asset, int64_t rowid) in UpdateLocalAsset() argument
338 string sql = "UPDATE " + tableName + " SET assert = ? where rowid = '" + std::to_string(rowid) + "';"; in UpdateLocalAsset()
726 * @tc.steps: rowid set is empty in HWTEST_F()
730 syncData.insData.rowid.push_back(1); in HWTEST_F()
731 syncData.insData.rowid.push_back(2); // 2 is random id in HWTEST_F()
744 * @tc.steps: the size of rowid and insData is not equal in HWTEST_F()
913 UpdateLocalAsset(g_tableName, asset, 2L); // 2 is rowid in HWTEST_F()
1106 syncData.updData.rowid.push_back(1L); in HWTEST_F()
1127 ASSERT_EQ(SQLiteUtils::GetStatement(db, "SELECT assert, asserts FROM " + g_tableName + " WHERE rowid in HWTEST_F()
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/
H A Drelational_sync_able_storage.cpp1559 errCode = FillReferenceDataIntoExtend(syncData.insData.rowid, referenceGid, syncData.insData.extend); in FillReferenceData()
1569 return FillReferenceDataIntoExtend(syncData.updData.rowid, referenceGid, syncData.updData.extend); in FillReferenceData()
1572 int RelationalSyncAbleStorage::FillReferenceDataIntoExtend(const std::vector<int64_t> &rowid, in FillReferenceDataIntoExtend() argument
1579 for (size_t index = 0u; index < rowid.size(); index++) { in FillReferenceDataIntoExtend()
1584 int64_t rowId = rowid[index]; in FillReferenceDataIntoExtend()
1912 const auto &rowId = updateData.rowid[i]; in UpdateRecordFlagAfterUpload()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/
H A Dcloud_sync_utils.cpp33 // The single primary key table, does not contain rowid. in GetCloudPkVals()
248 std::vector<int64_t>().swap(uploadData.insData.rowid); in ClearCloudSyncData()
290 uploadData.lockData.rowid.empty(); in CheckCloudSyncDataEmpty()
H A Dcloud_syncer.cpp493 * UpdateChangedData will be used for Insert case, which we can only get rowid after we saved data in db.
532 // no primary key or composite primary key, the first element is rowid in UpdateChangedData()
884 // save the data to the database by batch, downloadData will return rowid when insert data. in SaveData()
1220 if (!uploadData.lockData.rowid.empty()) { in SaveUploadData()
2032 // only no primary key and composite primary key contains rowid. in GetSyncParamForDownload()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/relational/
H A Drelational_sync_able_storage.h246 static int FillReferenceDataIntoExtend(const std::vector<int64_t> &rowid,
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/
H A Ddistributeddb_interfaces_relational_test.cpp1168 int rowid; member
1181 rowData.logInfo.dataKey = rowid; in operator ()()
1188 DBCommon::StringToVector(std::to_string(rowid), key); in operator ()()
1910 sql = "create table " + t2 + "(rowid int);"; in HWTEST_F()
1916 sql = "create table " + t4 + "(rowid int, oid int, _rowid_ text);"; in HWTEST_F()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/
H A Dsqlite_single_ver_storage_executor.cpp804 LOGE("[SqlSinExe][OpenResSetRowId][PrefixKey] Bind rowid stmt fail, errCode=%d", errCode); in OpenResultSetForCacheRowIdMode()
857 LOGE("Rebind result set rowid statement of keyPrefix error:%d", errCode); in ReloadResultSet()
876 errCode = helper.GetQuerySql(sql, true); // only rowid sql in ReloadResultSet()
890 LOGE("Rebind result set rowid statement of query error:%d", errCode); in ReloadResultSet()
1810 LOGE("Get result set rowid statement error:%d", errCode); in InitResultSet()
1822 LOGE("Bind result set rowid statement error:%d", errCode); in InitResultSet()
1865 LOGE("[SqlSinExe][InitResSetContent] Bind result set rowid statement of query error:%d", errCode); in InitResultSetContent()
2023 int64_t rowid = sqlite3_column_int64(getResultRowIdStatement_, 0); in ResultSetLoadRowIdCache() local
2024 rowIdCache.push_back(rowid); in ResultSetLoadRowIdCache()

Completed in 38 milliseconds