Home
last modified time | relevance | path

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

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/
H A Dcloud_sync_log_table_manager.cpp95 std::string insertTrigger = "CREATE TRIGGER IF NOT EXISTS "; in GetInsertTrigger() local
97 insertTrigger += "ON '" + tableName + "'\n"; in GetInsertTrigger()
100 insertTrigger += "BEGIN\n"; in GetInsertTrigger()
102 insertTrigger += "\t INSERT OR REPLACE INTO " + logTblName; in GetInsertTrigger()
111 insertTrigger += table.GetTrackerTable().GetAssignValSql(); in GetInsertTrigger()
115 insertTrigger += "), '', 0);\n"; in GetInsertTrigger()
118 insertTrigger += ", 0, "; in GetInsertTrigger()
120 insertTrigger += ");\n"; in GetInsertTrigger()
121 insertTrigger += "END;"; in GetInsertTrigger()
122 return insertTrigger; in GetInsertTrigger()
[all …]
H A Dsimple_tracker_log_table_manager.cpp65 std::string insertTrigger = "CREATE TRIGGER IF NOT EXISTS "; in GetInsertTrigger() local
67 insertTrigger += "ON '" + tableName + "'\n"; in GetInsertTrigger()
68 insertTrigger += " FOR EACH ROW \n"; in GetInsertTrigger()
69 insertTrigger += "BEGIN\n"; in GetInsertTrigger()
71 insertTrigger += "\t INSERT OR REPLACE INTO " + logTblName; in GetInsertTrigger()
75 insertTrigger += " get_raw_sys_time(), get_raw_sys_time(), 0x02, "; in GetInsertTrigger()
77 insertTrigger += table.GetTrackerTable().GetAssignValSql(); in GetInsertTrigger()
81 insertTrigger += ");\n"; in GetInsertTrigger()
82 insertTrigger += "END;"; in GetInsertTrigger()
83 return insertTrigger; in GetInsertTrigger()
[all …]
H A Dcollaboration_log_table_manager.cpp51 std::string insertTrigger = "CREATE TRIGGER IF NOT EXISTS "; in GetInsertTrigger() local
52 insertTrigger += "naturalbase_rdb_" + table.GetTableName() + "_ON_INSERT AFTER INSERT \n"; in GetInsertTrigger()
53 insertTrigger += "ON '" + table.GetTableName() + "'\n"; in GetInsertTrigger()
55 insertTrigger += "WHERE key = 'log_trigger_switch' AND value = 'true')\n"; in GetInsertTrigger()
56 insertTrigger += "BEGIN\n"; in GetInsertTrigger()
57 insertTrigger += "\t INSERT OR REPLACE INTO " + logTblName; in GetInsertTrigger()
60 insertTrigger += " get_sys_time(0), get_last_time(),"; in GetInsertTrigger()
63 insertTrigger += CalcPrimaryKeyHash("NEW.", table, identity) + ");\n"; in GetInsertTrigger()
64 insertTrigger += "END;"; in GetInsertTrigger()
65 return insertTrigger; in GetInsertTrigger()
[all …]
H A Dsplit_device_log_table_manager.cpp41 std::string insertTrigger = "CREATE TRIGGER IF NOT EXISTS "; in GetInsertTrigger() local
42 insertTrigger += "naturalbase_rdb_" + table.GetTableName() + "_ON_INSERT AFTER INSERT \n"; in GetInsertTrigger()
43 insertTrigger += "ON '" + table.GetTableName() + "'\n"; in GetInsertTrigger()
44 insertTrigger += "BEGIN\n"; in GetInsertTrigger()
45 insertTrigger += "\t INSERT OR REPLACE INTO " + logTblName; in GetInsertTrigger()
46 insertTrigger += " (data_key, device, ori_device, timestamp, wtimestamp, flag, hash_key)"; in GetInsertTrigger()
48 insertTrigger += " get_sys_time(0), get_last_time(),"; in GetInsertTrigger()
51 insertTrigger += CalcPrimaryKeyHash("NEW.", table, identity) + ");\n"; in GetInsertTrigger()
52 insertTrigger += "END;"; in GetInsertTrigger()
53 return insertTrigger; in GetInsertTrigger()
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/
H A Dsqlite_log_table_manager.cpp23 std::string insertTrigger = GetInsertTrigger(table, identity); in AddRelationalLogTableTrigger() local
24 if (!insertTrigger.empty()) { in AddRelationalLogTableTrigger()
25 sqls.emplace_back(insertTrigger); in AddRelationalLogTableTrigger()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/relational/
H A Drelational_store_sqlite_ext.cpp793 std::string insertTrigger = "CREATE TEMP TRIGGER IF NOT EXISTS "; in GetInsertTrigger() local
794 insertTrigger += "naturalbase_rdb_" + tableName + "_local_ON_INSERT AFTER INSERT\n"; in GetInsertTrigger()
795 insertTrigger += "ON '" + tableName + "'\n"; in GetInsertTrigger()
796 insertTrigger += "BEGIN\n"; in GetInsertTrigger()
798 insertTrigger += "SELECT data_change('" + tableName + "', 'rowid', NEW._rowid_, 0);\n"; in GetInsertTrigger()
800 insertTrigger += "SELECT data_change('" + tableName + "', "; in GetInsertTrigger()
801 … insertTrigger += "(SELECT name as a FROM pragma_table_info('" + tableName + "') WHERE pk=1), "; in GetInsertTrigger()
802 insertTrigger += "NEW." + primaryKey + ", 0);\n"; in GetInsertTrigger()
804 insertTrigger += "END;"; in GetInsertTrigger()
805 return insertTrigger; in GetInsertTrigger()