diff --git a/frameworks/libs/distributeddb/interfaces/include/relational/relational_store_client.h b/frameworks/libs/distributeddb/interfaces/include/relational/relational_store_client.h
index ee2c3a0db..936130637 100644
--- a/frameworks/libs/distributeddb/interfaces/include/relational/relational_store_client.h
+++ b/frameworks/libs/distributeddb/interfaces/include/relational/relational_store_client.h
@@ -51,4 +51,8 @@ DB_API DistributedDB::DBStatus Lock(const std::string &tableName, const std::vec
 
 DB_API DistributedDB::DBStatus UnLock(const std::string &tableName, const std::vector<std::vector<uint8_t>> &hashKey,
     sqlite3 *db);
+
+DB_API void RegisterDbHook(sqlite3 *db);
+
+DB_API void UnregisterDbHook(sqlite3 *db);
 #endif // RELATIONAL_STORE_CLIENT_H
diff --git a/frameworks/libs/distributeddb/interfaces/src/relational/relational_store_sqlite_ext.cpp b/frameworks/libs/distributeddb/interfaces/src/relational/relational_store_sqlite_ext.cpp
index d530d90e3..9897134bc 100644
--- a/frameworks/libs/distributeddb/interfaces/src/relational/relational_store_sqlite_ext.cpp
+++ b/frameworks/libs/distributeddb/interfaces/src/relational/relational_store_sqlite_ext.cpp
@@ -401,6 +401,8 @@ std::map<std::string, std::vector<ChangedData>> g_storeChangedDataMap;
 std::mutex g_clientCreateTableMutex;
 std::set<std::string> g_clientCreateTable;
 
+std::mutex g_registerSqliteHookMutex;
+
 int RegisterFunction(sqlite3 *db, const std::string &funcName, int nArg, void *uData, TransactFunc &func)
 {
     if (db == nullptr) {
@@ -1774,6 +1776,19 @@ DB_API DistributedDB::DBStatus UnLock(const std::string &tableName, const std::v
     return HandleDataLock(tableName, hashKey, db, false);
 }
 
+DB_API void RegisterDbHook(sqlite3 *db)
+{
+    std::lock_guard<std::mutex> lock(g_registerSqliteHookMutex);
+    sqlite3_wal_hook(db, LogCommitHookCallback, db);
+    sqlite3_rollback_hook(db, RollbackHookCallback, db);
+}
+
+DB_API void UnregisterDbHook(sqlite3 *db)
+{
+    std::lock_guard<std::mutex> lock(g_registerSqliteHookMutex);
+    sqlite3_wal_hook(db, nullptr, db);
+    sqlite3_rollback_hook(db, nullptr, db);
+}
 // hw export the symbols
 #ifdef SQLITE_DISTRIBUTE_RELATIONAL
 #if defined(__GNUC__)