| /ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/ |
| H A D | sqlite_sql_builder.cpp | 244 if (table.empty() || logTable.empty()) { in BuildCursorQueryString()
260 logTable + "." + SHARING_RESOURCE + " AS " + field); in BuildCursorQueryString()
263 sql.append(", " + logTable + ".cursor"); in BuildCursorQueryString()
264 sql.append(", CASE WHEN ").append(logTable).append(".") in BuildCursorQueryString()
266 sql.append(", CASE WHEN ").append(logTable).append("."); in BuildCursorQueryString()
273 .append(".ROWID = ").append(logTable).append(".data_key"); in BuildCursorQueryString()
279 SqliteUtils::Replace(order, SqliteUtils::REP, logTable + "."); in BuildCursorQueryString()
295 if (table.empty() || logTable.empty()) { in BuildLockRowQueryString()
309 sql.append(" INNER JOIN ").append(logTable).append(" ON "); in BuildLockRowQueryString()
313 …sql.append(" WHERE ").append(logTable).append(".status = 2 OR ").append(logTable).append(".status … in BuildLockRowQueryString()
[all …]
|
| H A D | rdb_store.cpp | 240 std::string logTable = GetLogTableName(table); in Query() local
241 sql = SqliteSqlBuilder::BuildCursorQueryString(predicates, columns, logTable, queryStatus); in Query()
264 std::string logTable = GetLogTableName(table); in QueryByStep() local
265 sql = SqliteSqlBuilder::BuildLockRowQueryString(predicates, columns, logTable); in QueryByStep()
|
| H A D | rdb_store_impl.cpp | 153 auto logTable = DistributedDB::RelationalStoreManager::GetDistributedLogTableName(table); in GetModifyTime() local
155 return GetModifyTimeByRowId(logTable, keys); in GetModifyTime()
176 sql.append(logTable); in GetModifyTime()
189 RdbStore::ModifyTime RdbStoreImpl::GetModifyTimeByRowId(const std::string &logTable, std::vector<PR… in GetModifyTimeByRowId() argument
193 sql.append(logTable); in GetModifyTimeByRowId()
772 auto logTable = GetLogTableName(table); in GetHashKeyForLockRow() local
774 sql.append("SELECT ").append(logTable).append(".hash_key ").append("FROM ").append(logTable); in GetHashKeyForLockRow()
776 sql.append(table).append(".ROWID = ").append(logTable).append(".data_key"); in GetHashKeyForLockRow()
779 SqliteUtils::Replace(whereClause, SqliteUtils::REP, logTable + "."); in GetHashKeyForLockRow()
|
| /ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/include/ |
| H A D | sqlite_sql_builder.h | 53 …const std::vector<std::string> &columns, const std::string &logTable, const std::pair<bool, bool> …
55 …bsRdbPredicates &predicates, const std::vector<std::string> &columns, const std::string &logTable);
|
| H A D | rdb_store_impl.h | 191 ModifyTime GetModifyTimeByRowId(const std::string &logTable, std::vector<PRIKey> &keys);
|
| /ohos5.0/foundation/distributeddatamgr/relational_store/test/native/rdb/unittest/ |
| H A D | rdb_step_result_set_test.cpp | 1477 std::string logTable = "naturalbase_rdb_aux_test_log"; variable
1494 …sqlstr = SqliteSqlBuilder::BuildCursorQueryString(emptyPredicates, columns, logTable, queryStatus);
1498 sqlstr = SqliteSqlBuilder::BuildCursorQueryString(predicates, columns, logTable, queryStatus);
1512 sqlstr = SqliteSqlBuilder::BuildCursorQueryString(predicates, columns, logTable, queryStatus);
1533 std::string logTable = "naturalbase_rdb_aux_test_log"; variable
1541 sqlstr = SqliteSqlBuilder::BuildCursorQueryString(predicates, columns, logTable, queryStatus);
1549 sqlstr = SqliteSqlBuilder::BuildCursorQueryString(predicates, columns, logTable, queryStatus);
1557 sqlstr = SqliteSqlBuilder::BuildCursorQueryString(predicates, columns, logTable, queryStatus);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/ |
| H A D | sqlite_single_ver_relational_storage_extend_executor.cpp | 481 std::string logTable = DBCommon::GetLogTableName(tableInfo.GetTableName()); in UpgradedLogForExistedData() local
483 std::string markAsInconsistent = "UPDATE " + logTable + " SET flag=" + in UpgradedLogForExistedData()
973 std::string logTable = DBConstant::RELATIONAL_PREFIX + tableName + "_log"; in CleanExtendAndCursorForDeleteData() local
974 std::string sql = "DELETE FROM " + logTable + " where flag&0x01=0x01;"; in CleanExtendAndCursorForDeleteData()
1008 std::string logTable = DBCommon::GetLogTableName(table); in GetCloudDeleteSql() local
|
| H A D | sqlite_single_ver_relational_storage_executor.cpp | 180 std::string logTable = DBConstant::RELATIONAL_PREFIX + tableName + "_log"; in GeneLogInfoForExistedData() local
185 …std::string sql = "INSERT OR REPLACE INTO " + logTable + " SELECT " + rowid + ", '', '', " + timeO… in GeneLogInfoForExistedData()
196 std::string sql = "INSERT OR REPLACE INTO " + logTable + " SELECT " + rowid + in GeneLogInfoForExistedData()
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/ |
| H A D | rdb_general_store.cpp | 637 auto logTable = RelationalStoreManager::GetDistributedLogTableName(table); in BuildSql() local
638 sql.append(" from ").append(logTable).append(", (").append(sqlNode); in BuildSql()
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/cloud/ |
| H A D | cloud_service_impl.cpp | 505 …std::string logTable = DistributedDB::RelationalStoreManager::GetDistributedLogTableName(tableName… in BuildStatisticSql() local
510 sql.append(" from ").append(logTable); in BuildStatisticSql()
|