Home
last modified time | relevance | path

Searched refs:updateTrigger (Results 1 – 6 of 6) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/
H A Dsimple_tracker_log_table_manager.cpp94 std::string updateTrigger = "CREATE TRIGGER IF NOT EXISTS "; in GetUpdateTrigger() local
96 updateTrigger += "ON '" + tableName + "'\n"; in GetUpdateTrigger()
97 updateTrigger += " FOR EACH ROW "; in GetUpdateTrigger()
99 updateTrigger += CloudStorageUtils::GetCursorIncSql(tableName); in GetUpdateTrigger()
100 updateTrigger.pop_back(); in GetUpdateTrigger()
102 updateTrigger += "\t UPDATE " + logTblName; in GetUpdateTrigger()
108 updateTrigger += ", 1, "; in GetUpdateTrigger()
110 updateTrigger += ");"; in GetUpdateTrigger()
111 updateTrigger += "END;"; in GetUpdateTrigger()
112 return updateTrigger; in GetUpdateTrigger()
[all …]
H A Dsplit_device_log_table_manager.cpp59 std::string updateTrigger = "CREATE TRIGGER IF NOT EXISTS "; in GetUpdateTrigger() local
61 updateTrigger += "ON '" + table.GetTableName() + "'\n"; in GetUpdateTrigger()
62 updateTrigger += "BEGIN\n"; in GetUpdateTrigger()
66 updateTrigger += " SET timestamp=get_sys_time(0), device='', flag=0x22"; in GetUpdateTrigger()
67 updateTrigger += " WHERE hash_key=" + CalcPrimaryKeyHash("OLD.", table, identity) + in GetUpdateTrigger()
73 updateTrigger += "\t UPDATE " + logTblName; in GetUpdateTrigger()
74 updateTrigger += " SET data_key=-1,timestamp=get_sys_time(0), device='', flag=0x03"; in GetUpdateTrigger()
76 updateTrigger += "\t INSERT OR REPLACE INTO " + logTblName + " VALUES (NEW." + in GetUpdateTrigger()
82 updateTrigger += "END;"; in GetUpdateTrigger()
83 return updateTrigger; in GetUpdateTrigger()
[all …]
H A Dcollaboration_log_table_manager.cpp71 std::string updateTrigger = "CREATE TRIGGER IF NOT EXISTS "; in GetUpdateTrigger() local
73 updateTrigger += "ON '" + table.GetTableName() + "'\n"; in GetUpdateTrigger()
75 updateTrigger += "WHERE key = 'log_trigger_switch' AND value = 'true')\n"; in GetUpdateTrigger()
76 updateTrigger += "BEGIN\n"; in GetUpdateTrigger()
80 updateTrigger += " SET timestamp=get_sys_time(0), device='', flag=0x22"; in GetUpdateTrigger()
86 updateTrigger += "\t UPDATE " + logTblName; in GetUpdateTrigger()
87 updateTrigger += " SET data_key=-1, timestamp=get_sys_time(0), device='', flag=0x03"; in GetUpdateTrigger()
89 updateTrigger += "\t INSERT OR REPLACE INTO " + logTblName + " VALUES (NEW." + in GetUpdateTrigger()
96 updateTrigger += "END;"; in GetUpdateTrigger()
97 return updateTrigger; in GetUpdateTrigger()
[all …]
H A Dcloud_sync_log_table_manager.cpp130 std::string updateTrigger = "CREATE TRIGGER IF NOT EXISTS "; in GetUpdateTrigger() local
132 updateTrigger += "ON '" + tableName + "'\n"; in GetUpdateTrigger()
137 updateTrigger += "\t UPDATE " + logTblName; in GetUpdateTrigger()
143 updateTrigger += CloudStorageUtils::GetUpdateLockChangedSql(); in GetUpdateTrigger()
147 updateTrigger += std::string(DBConstant::SQLITE_INNER_ROWID); in GetUpdateTrigger()
148 updateTrigger += ", 1, "; in GetUpdateTrigger()
149 updateTrigger += table.GetTrackerTable().GetDiffTrackerValSql(); in GetUpdateTrigger()
150 updateTrigger += ");"; in GetUpdateTrigger()
151 updateTrigger += "END;"; in GetUpdateTrigger()
152 return updateTrigger; in GetUpdateTrigger()
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/
H A Dsqlite_log_table_manager.cpp27 std::string updateTrigger = GetUpdateTrigger(table, identity); in AddRelationalLogTableTrigger() local
28 if (!updateTrigger.empty()) { in AddRelationalLogTableTrigger()
29 sqls.emplace_back(updateTrigger); in AddRelationalLogTableTrigger()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/relational/
H A Drelational_store_sqlite_ext.cpp810 std::string updateTrigger = "CREATE TEMP TRIGGER IF NOT EXISTS "; in GetUpdateTrigger() local
811 updateTrigger += "naturalbase_rdb_" + tableName + "_local_ON_UPDATE AFTER UPDATE\n"; in GetUpdateTrigger()
812 updateTrigger += "ON '" + tableName + "'\n"; in GetUpdateTrigger()
813 updateTrigger += "BEGIN\n"; in GetUpdateTrigger()
815 updateTrigger += "SELECT data_change('" + tableName + "', 'rowid', NEW._rowid_, 1);\n"; in GetUpdateTrigger()
817 updateTrigger += "SELECT data_change('" + tableName + "', "; in GetUpdateTrigger()
818 … updateTrigger += "(SELECT name as a FROM pragma_table_info('" + tableName + "') WHERE pk=1), "; in GetUpdateTrigger()
819 updateTrigger += "NEW." + primaryKey + ", 1);\n"; in GetUpdateTrigger()
821 updateTrigger += "END;"; in GetUpdateTrigger()
822 return updateTrigger; in GetUpdateTrigger()