anlicheng/iot
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

close mnesia

Browse Source
This commit is contained in:
anlicheng 2024-08-12 22:40:20 +08:00
parent 2062c5612c
commit 230eee53dc
1 changed files with 29 additions and 29 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

58
apps/iot/src/iot_app.erl
View File

@ -17,7 +17,7 @@ start(_StartType, _StartArgs) ->
erlang:system_flag(fullsweep_after, 16), erlang:system_flag(fullsweep_after, 16),
%% 启动数据库 %% 启动数据库
start_mnesia(), % start_mnesia(),
{ok, SupPid} = iot_sup:start_link(), {ok, SupPid} = iot_sup:start_link(),
%% 启动udp服务 %% 启动udp服务
@ -69,31 +69,31 @@ start_udp_server() ->
lager:debug("[iot_app] the udp server start at: ~p", [Port]). lager:debug("[iot_app] the udp server start at: ~p", [Port]).
%% 启动内存数据库 %% 启动内存数据库
start_mnesia() -> %start_mnesia() ->
%% 启动数据库 % %% 启动数据库
ok = mnesia:start(), % ok = mnesia:start(),
Tables = mnesia:system_info(tables), % Tables = mnesia:system_info(tables),
%
LoadTables = [totalizator], % LoadTables = [totalizator],
case lists:all(fun(Tab) -> lists:member(Tab, Tables) end, LoadTables) of % case lists:all(fun(Tab) -> lists:member(Tab, Tables) end, LoadTables) of
true -> % true ->
lager:debug("[iot_app] waiting for mnesia start: ~p", [LoadTables]), % lager:debug("[iot_app] waiting for mnesia start: ~p", [LoadTables]),
%% 加载必须等待的数据库表 % %% 加载必须等待的数据库表
mnesia:wait_for_tables(LoadTables, infinity), % mnesia:wait_for_tables(LoadTables, infinity),
lager:debug("[iot_app] waiting for mnesia end"); % lager:debug("[iot_app] waiting for mnesia end");
false -> % false ->
lager:warning("[iot_app] tables: ~p not exists, recreate mnesia schema", [LoadTables]), % lager:warning("[iot_app] tables: ~p not exists, recreate mnesia schema", [LoadTables]),
%% 清理掉以前的schema % %% 清理掉以前的schema
mnesia:stop(), % mnesia:stop(),
mnesia:delete_schema([node()]), % mnesia:delete_schema([node()]),
%
%% 创建schema % %% 创建schema
ok = mnesia:create_schema([node()]), % ok = mnesia:create_schema([node()]),
ok = mnesia:start(), % ok = mnesia:start(),
%
%% 创建数据库表 % %% 创建数据库表
%% id生成器 % %% id生成器
%% mnesia_id_generator:create_table(), % %% mnesia_id_generator:create_table(),
%% 大数据统计表 % %% 大数据统计表
mnesia_totalizator:create_table() % mnesia_totalizator:create_table()
end. % end.