Home
last modified time | relevance | path

Searched refs:deleteTrigger (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.cpp122 std::string deleteTrigger = "CREATE TRIGGER IF NOT EXISTS "; in GetDeleteTrigger() local
124 deleteTrigger += "ON '" + tableName + "'\n"; in GetDeleteTrigger()
125 deleteTrigger += " FOR EACH ROW \n"; in GetDeleteTrigger()
126 deleteTrigger += "BEGIN\n"; in GetDeleteTrigger()
127 deleteTrigger += CloudStorageUtils::GetCursorIncSql(tableName) + "\n"; in GetDeleteTrigger()
128 deleteTrigger += "\t UPDATE " + GetLogTableName(table); in GetDeleteTrigger()
130 deleteTrigger += table.GetTrackerTable().GetExtendAssignValSql(true); in GetDeleteTrigger()
136 deleteTrigger += ");\n"; in GetDeleteTrigger()
137 deleteTrigger += "END;"; in GetDeleteTrigger()
138 return deleteTrigger; in GetDeleteTrigger()
[all …]
H A Dcloud_sync_log_table_manager.cpp160 std::string deleteTrigger = "CREATE TRIGGER IF NOT EXISTS "; in GetDeleteTrigger() local
162 deleteTrigger += "ON '" + tableName + "'\n"; in GetDeleteTrigger()
165 deleteTrigger += "BEGIN\n"; in GetDeleteTrigger()
167 deleteTrigger += "\t UPDATE " + GetLogTableName(table); in GetDeleteTrigger()
168 deleteTrigger += " SET data_key=-1,"; in GetDeleteTrigger()
174 deleteTrigger += "timestamp=get_raw_sys_time()"; in GetDeleteTrigger()
179 deleteTrigger += CloudStorageUtils::GetDeleteLockChangedSql(); in GetDeleteTrigger()
185 deleteTrigger += ");\n"; in GetDeleteTrigger()
186 deleteTrigger += "END;"; in GetDeleteTrigger()
187 return deleteTrigger; in GetDeleteTrigger()
[all …]
H A Dcollaboration_log_table_manager.cpp103 std::string deleteTrigger = "CREATE TRIGGER IF NOT EXISTS "; in GetDeleteTrigger() local
104 deleteTrigger += "naturalbase_rdb_" + table.GetTableName() + "_ON_DELETE BEFORE DELETE \n"; in GetDeleteTrigger()
105 deleteTrigger += "ON '" + table.GetTableName() + "'\n"; in GetDeleteTrigger()
106 deleteTrigger += "WHEN (SELECT count(*) from " + DBConstant::RELATIONAL_PREFIX + "metadata "; in GetDeleteTrigger()
107 deleteTrigger += "WHERE key = 'log_trigger_switch' AND VALUE = 'true')\n"; in GetDeleteTrigger()
108 deleteTrigger += "BEGIN\n"; in GetDeleteTrigger()
109 deleteTrigger += "\t UPDATE " + DBConstant::RELATIONAL_PREFIX + table.GetTableName() + "_log"; in GetDeleteTrigger()
110 deleteTrigger += " SET data_key=-1,flag=0x03,timestamp=get_sys_time(0)"; in GetDeleteTrigger()
112 deleteTrigger += "END;"; in GetDeleteTrigger()
113 return deleteTrigger; in GetDeleteTrigger()
[all …]
H A Dsplit_device_log_table_manager.cpp88 std::string deleteTrigger = "CREATE TRIGGER IF NOT EXISTS "; in GetDeleteTrigger() local
89 deleteTrigger += "naturalbase_rdb_" + table.GetTableName() + "_ON_DELETE BEFORE DELETE \n"; in GetDeleteTrigger()
90 deleteTrigger += "ON '" + table.GetTableName() + "'\n"; in GetDeleteTrigger()
91 deleteTrigger += "BEGIN\n"; in GetDeleteTrigger()
92 deleteTrigger += "\t UPDATE " + DBConstant::RELATIONAL_PREFIX + table.GetTableName() + "_log"; in GetDeleteTrigger()
93 deleteTrigger += " SET data_key=-1,flag=0x03,timestamp=get_sys_time(0)"; in GetDeleteTrigger()
94 deleteTrigger += " WHERE hash_key=" + CalcPrimaryKeyHash("OLD.", table, identity) + in GetDeleteTrigger()
96 deleteTrigger += "END;"; in GetDeleteTrigger()
97 return deleteTrigger; in GetDeleteTrigger()
111 …std::string deleteTrigger = "DROP TRIGGER IF EXISTS naturalbase_rdb_" + tableName + "_ON_DELETE; "; in GetDropTriggers() local
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/
H A Dsqlite_log_table_manager.cpp31 std::string deleteTrigger = GetDeleteTrigger(table, identity); in AddRelationalLogTableTrigger() local
32 if (!deleteTrigger.empty()) { in AddRelationalLogTableTrigger()
33 sqls.emplace_back(deleteTrigger); in AddRelationalLogTableTrigger()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/relational/
H A Drelational_store_sqlite_ext.cpp827 std::string deleteTrigger = "CREATE TEMP TRIGGER IF NOT EXISTS "; in GetDeleteTrigger() local
828 deleteTrigger += "naturalbase_rdb_" + tableName + "_local_ON_DELETE AFTER DELETE\n"; in GetDeleteTrigger()
829 deleteTrigger += "ON '" + tableName + "'\n"; in GetDeleteTrigger()
830 deleteTrigger += "BEGIN\n"; in GetDeleteTrigger()
832 deleteTrigger += "SELECT data_change('" + tableName + "', 'rowid', OLD._rowid_, 2);\n"; in GetDeleteTrigger()
834 deleteTrigger += "SELECT data_change('" + tableName + "', "; in GetDeleteTrigger()
835 … deleteTrigger += "(SELECT name as a FROM pragma_table_info('" + tableName + "') WHERE pk=1), "; in GetDeleteTrigger()
836 deleteTrigger += "OLD." + primaryKey + ", 2);\n"; in GetDeleteTrigger()
838 deleteTrigger += "END;"; in GetDeleteTrigger()
839 return deleteTrigger; in GetDeleteTrigger()