diff --git a/apps/efka/src/efka_app.erl b/apps/efka/src/efka_app.erl index 9f7f2a7..55a0113 100644 --- a/apps/efka/src/efka_app.erl +++ b/apps/efka/src/efka_app.erl @@ -34,6 +34,6 @@ start_mnesia() -> lager:debug("[efka_app] tables: ~p", [Tables]), %% 创建数据库表 not lists:member(id_generator, Tables) andalso id_generator_model:create_table(), - not lists:member(micro_service, Tables) andalso service_model:create_table(), - not lists:member(micro_data, Tables) andalso micro_data_model:create_table(), + not lists:member(service, Tables) andalso service_model:create_table(), + not lists:member(cache, Tables) andalso cache_model:create_table(), ok. \ No newline at end of file diff --git a/apps/efka/src/mnesia/cache_model.erl b/apps/efka/src/mnesia/cache_model.erl index 6ff2b8e..d855a5e 100644 --- a/apps/efka/src/mnesia/cache_model.erl +++ b/apps/efka/src/mnesia/cache_model.erl @@ -11,7 +11,7 @@ -include("efka_tables.hrl"). -include_lib("stdlib/include/qlc.hrl"). --define(TAB, micro_data). +-define(TAB, cache). %% API -export([create_table/0]). @@ -19,9 +19,9 @@ create_table() -> %% id生成器 - mnesia:create_table(micro_cache, [ - {attributes, record_info(fields, micro_cache)}, - {record_name, micro_cache}, + mnesia:create_table(cache, [ + {attributes, record_info(fields, cache)}, + {record_name, cache}, {disc_copies, [node()]}, {type, ordered_set} ]). diff --git a/apps/efka/src/mnesia/service_model.erl b/apps/efka/src/mnesia/service_model.erl index d17fcc9..35d5d50 100644 --- a/apps/efka/src/mnesia/service_model.erl +++ b/apps/efka/src/mnesia/service_model.erl @@ -11,7 +11,7 @@ -include("efka_tables.hrl"). -include_lib("stdlib/include/qlc.hrl"). --define(TAB, micro_service). +-define(TAB, service). %% API -export([create_table/0]). @@ -20,15 +20,15 @@ create_table() -> %% id生成器 - mnesia:create_table(micro_service, [ - {attributes, record_info(fields, micro_service)}, - {record_name, micro_service}, + mnesia:create_table(service, [ + {attributes, record_info(fields, service)}, + {record_name, service}, {disc_copies, [node()]}, {type, ordered_set} ]). -insert(MicroService = #service{}) -> - case mnesia:transaction(fun() -> mnesia:write(micro_service, MicroService, write) end) of +insert(Service = #service{}) -> + case mnesia:transaction(fun() -> mnesia:write(?TAB, Service, write) end) of {'atomic', Res} -> Res; {'aborted', Reason} ->