chore(persist): get persist db

emqx · Mar 17, 2023 · c3ed9cc · c3ed9cc
1 parent 54dfc37
commit c3ed9cc
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 1 deletion.
diff --git a/src/adapter/adapter_info.h → include/neuron/adapter_info.h b/src/adapter/adapter_info.h → include/neuron/adapter_info.h
diff --git a/include/neuron/persist/persist.h b/include/neuron/persist/persist.h
@@ -24,7 +24,9 @@
 extern "C" {
 #endif
 
-#include "adapter/adapter_info.h"
+#include <sqlite3.h>
+
+#include "adapter_info.h"
 #include "persist/json/persist_json_plugin.h"
 
 typedef neu_json_plugin_req_plugin_t neu_persist_plugin_info_t;
@@ -90,6 +92,8 @@ int neu_persister_create(const char *schema_dir);
  */
 void neu_persister_destroy();
 
+sqlite3 *neu_persister_get_db();
+
 /**
  * Persist nodes.
  * @param node_info                 neu_persist_node_info_t.

diff --git a/src/persist/persist.c b/src/persist/persist.c
@@ -465,6 +465,11 @@ int neu_persister_create(const char *schema_dir)
     return 0;
 }
 
+sqlite3 *neu_persister_get_db()
+{
+    return global_db;
+}
+
 void neu_persister_destroy()
 {
     sqlite3_close(global_db);