`
cwqcwk1
  • 浏览: 87291 次
文章分类
社区版块
存档分类
最新评论

erlang mnesia 数据库实现SQL查询

 
阅读更多

Mnesia是一个分布式数据库管理系统,适合于电信和其它需要持续运行和具备软实时特性的Erlang应用,越来越受关注和使用,但是目前Mnesia资料却不多,很多都只有官方的用户指南。下面的内容将着重说明 Mnesia 数据库如何实现SQL查询,实现select / insert / update / where / order by / join / limit / delete等SQL操作。

示例中表结构的定义:

%% 账号表结构 
-record( y_account,{ id, account, password }).

%% 资料表结构  
-record( y_info, { id, nickname, birthday, sex }). 

1、Create Table / Delete Table 操作

%%===============================================
%%  create table y_account ( id int, account varchar(50),
%%   password varchar(50),  primary key(id)) ;
%%===============================================

%% 使用 mnesia:create_table
mnesia:create_table( y_account,[{attributes, record_info(fields, y_account)} ,
  {type,set}, {disc_copies, [node()]} ]).

%%===============================================
%%  drop table y_account;
%%===============================================

%% 使用 mnesia:delete_table
mnesia:delete_table(y_account) .

注:参数意义可以看文档,{type,set} 表示id作为主键,不允许id重复,如果改为 {type,bag},id可以重复,但整条记录不能重复

2、Select 查询

查询全部记录

%%===============================================
%%  select * from y_account
%%===============================================

%% 使用 mnesia:select
F = fun() ->
	MatchHead = #y_account{ _ = '_' },
	Guard = [],
	Result = ['$_'],
	mnesia:select(y_account, [{MatchHead, Guard, Result}])
end,
mnesia:transaction(F).

%% 使用 qlc
F = fun() ->
	Q = qlc:q([E || E <- mnesia:table(y_account)]),
	qlc:e(Q)
end,
mnesia:transaction(F).

查询部分字段的记录

%%===============================================
%%  select id,account from y_account
%%===============================================

%% 使用 mnesia:select
F = fun() ->
	MatchHead = #y_account{id = '$1', account = '$2', _ = '_' },
	Guard = [],
	Result = ['$$'],
	mnesia:select(y_account, [{MatchHead, Guard, Result}])
end,
mnesia:transaction(F).

%% 使用 qlc
F = fun() ->
	Q = qlc:q([[E#y_account.id, E#y_account.account] || E <- mnesia:table(y_account)]),
	qlc:e(Q)
end,
mnesia:transaction(F).

3、Insert / Update 操作

mnesia是根据主键去更新记录的,如果主键不存在则插入

%%===============================================
%%    insert into y_account (id,account,password) values(5,"xiaohong","123")
%%     on duplicate key update account="xiaohong",password="123";
%%===============================================

%% 使用 mnesia:write
F = fun() ->
	Acc = #y_account{id = 5, account="xiaohong", password="123"},
	mnesia:write(Acc)
end,
mnesia:transaction(F).

4、Where 查询

%%===============================================
%%    select account from y_account where id>5
%%===============================================

%% 使用 mnesia:select
F = fun() ->
	MatchHead = #y_account{id = '$1', account = '$2', _ = '_' },
	Guard = [{'>', '$1', 5}],
	Result = ['$2'],
	mnesia:select(y_account, [{MatchHead, Guard, Result}])
end,
mnesia:transaction(F).

%% 使用 qlc
F = fun() ->
	Q = qlc:q([E#y_account.account || E <- mnesia:table(y_account), E#y_account.id>5]),
	qlc:e(Q)
end,
mnesia:transaction(F).

如果查找主键 key=X 的记录,还可以这样子查询:

%%===============================================
%%   select * from y_account where id=5
%%===============================================

F = fun() ->
	mnesia:read({y_account,5})
end,
mnesia:transaction(F).

如果查找非主键 field=X 的记录,可以如下查询:

%%===============================================
%%   select * from y_account where account='xiaomin'
%%===============================================

F = fun() ->
	MatchHead = #y_account{ id = '_', account = "xiaomin", password = '_' },
	Guard = [],
	Result = ['$_'],
	mnesia:select(y_account, [{MatchHead, Guard, Result}])
end,
mnesia:transaction(F).

5、Order By 查询

%%===============================================
%%   select * from y_account order by id asc
%%===============================================

%% 使用 qlc
F = fun() ->
	Q = qlc:q([E || E <- mnesia:table(y_account)]),
	qlc:e(qlc:keysort(2, Q, [{order, ascending}]))
end,
mnesia:transaction(F).

%% 使用 qlc 的第二种写法
F = fun() ->  
	Q = qlc:q([E || E <- mnesia:table(y_account)]), 
	Order = fun(A, B) ->
		B#y_account.id > A#y_account.id
	end,
	qlc:e(qlc:sort(Q, [{order, Order}]))
end,  
mnesia:transaction(F).

6、Join 关联表查询

%%===============================================
%%   select y_info.* from y_account join y_info on (y_account.id = y_info.id)
%%      where y_account.account = 'xiaomin'
%%===============================================

%% 使用 qlc
F = fun() ->
	Q = qlc:q([Y || X <- mnesia:table(y_account),
		X#y_account.account =:= "xiaomin",
		Y <- mnesia:table(y_info),
		X#y_account.id =:= Y#y_info.id
	]),
	qlc:e(Q)
end,
mnesia:transaction(F).

7、Limit 查询

%%===============================================
%%   select * from y_account limit 2
%%===============================================

%% 使用 mnesia:select
F = fun() ->
	MatchHead = #y_account{ _ = '_' }, 
	mnesia:select(y_account, [{MatchHead, [], ['$_']}], 2, none)
end,
mnesia:transaction(F).

%% 使用 qlc
F = fun() ->
	Q = qlc:q([E || E <- mnesia:table(y_account)]),
	QC = qlc:cursor(Q),
	qlc:next_answers(QC, 2)
end,
mnesia:transaction(F).

8、Select count(*) 查询

%%===============================================
%%   select count(*) from y_account
%%===============================================

%% 使用 mnesia:table_info
F = fun() ->
	mnesia:table_info(y_account, size)
end,
mnesia:transaction(F).

9、Delete 查询

%%===============================================
%%   delete from y_account where id=5
%%===============================================

%% 使用 mnesia:delete
F = fun() ->
	mnesia:delete({y_account, 5})
end,
mnesia:transaction(F).


注:使用qlc模块查询,需要在文件顶部声明“-include_lib("stdlib/include/qlc.hrl").”,否则编译时会产生“Warning: qlc:q/1 called, but "qlc.hrl" not included”的警告。

更新说明:

2013/11/20 补充了 mnesia:select 方式的 limit 查询

分享到:
评论

相关推荐

    mnesia数据库文档

    ### Mnesia数据库:Erlang中的分布式数据库管理系统 #### 引言 Mnesia,作为Erlang编程语言的一部分,是一款由爱立信公司开发的分布式数据库管理系统(DBMS)。自1997年以来,Mnesia一直是Open Telecom Platform...

    Erlang Mnesia

    - Mnesia 提供了一种基于SQL的查询语言,称为QL,它简化了对数据的操作,使开发者能够方便地进行数据检索和更新。 **4. 安全性** - Mnesia 包含了对安全性的支持,如身份验证、访问控制等机制,确保敏感数据的...

    Mnesia用户手册.zip

    《Mnesia用户手册》是专为理解和操作Erlang编程语言中的Mnesia数据库管理系统而编写的详尽指南。Mnesia是Erlang OTP (Open Telephony Platform) 库中的一个核心组件,它是一个强大的分布式数据库系统,特别适用于...

    Mnesia用户手册(docx版)

    Mnesia 是一个强大的分布式数据库管理系统(DBMS),专门为Erlang编程语言设计,特别适用于需要高可用性、持续运行和软实时特性的电信和其他关键业务应用。这个系统允许在多个节点间同步数据,提供了一种在分布式...

    Mnesia用户手册

    同时,Mnesia也支持高级查询功能,如QLC(Query List Comprehension),提供更接近SQL的查询体验。 **6. 数据库操作** Mnesia提供了丰富的API函数来管理数据库,包括创建、删除表,插入、更新和删除记录,以及执行...

    Erlang6大数据存储方式总结

    虽然MySQL不是Erlang原生的存储解决方案,但其强大的SQL查询能力和成熟的社区支持使其在处理复杂查询和大规模数据时表现出色。通过Erlang与MySQL的集成,开发者可以利用两者的优点,构建混合型的存储解决方案。 ...

    mnesia_pg:Postgres后端通过mnesia_ext到Mnesia

    2. **Mnesia数据库**:Mnesia是Erlang OTP库的一部分,它是一个内存交易数据库,支持分布式和本地模式,适用于实时系统。理解Mnesia的数据模型,事务处理,以及如何在Erlang应用中集成Mnesia。 3. **PostgreSQL...

    erlang emysql

    Erlang是一种并发和分布式系统设计的强大工具,而emysql则提供了连接和操作MySQL数据库的接口,使得开发者能够方便地在Erlang应用中实现数据存储和查询功能。 在深入emysql之前,我们首先了解Erlang的基本概念。...

    estore:SQL和NoSQL存储后端上的Erlang抽象层

    这个抽象层允许开发者在SQL(结构化查询语言,如PostgreSQL)和NoSQL(非关系型数据库,如Mnesia和Elasticsearch)存储之间进行切换,而无需大幅修改代码,提高了代码的可移植性和灵活性。 **描述分析:** 描述中...

    amnesia-开源

    在AMNESIA中,数据库操作被抽象化,使得程序员可以使用Erlang的本机数据类型和语言结构来处理数据库操作,而不是传统的SQL语句。这种方式使得代码更加简洁,同时也保持了Erlang的编程风格和并发特性。例如,通过A...

    DBMS.rar_dbms_symbian_symbian DBMS

    如果是数据库文件,可能是SQLite或Mnesia的数据库格式,用于演示如何在Symbian上操作和查询数据。如果是源代码文件,那么可能包含了一些数据库操作的API调用示例,比如创建表、执行查询、事务处理等。 在开发...

    NoSQL数据库笔谈

    - **Mnesia**: Erlang语言下的分布式数据库。 - **LightCloud**: 基于Erlang的NoSQL数据库。 - **HamsterDB**: 高性能的嵌入式数据库。 - **Flare**: 分布式的键值存储系统。 **9. 最终一致性KeyValue存储** - **...

    NoSQL数据库详细介绍入门经典

    - **Mnesia**:Erlang平台上的分布式数据库管理系统。 - **LightCloud**:基于MongoDB的云托管服务。 - **HamsterDB**:一个高性能的嵌入式数据库。 - **Flare**:一个高性能的键值存储系统。 #### 应用篇 - *...

    2012年中国系统架构师大会PPT-_1 低成本和高性能MySQL云架构探索.pdf

    - 实现高效MySQL数据库服务支持,并实现自动化运维。 - 提升资源利用率,减少平台成本。 - 长期运行过程中,对外屏蔽软硬件变化的影响,进一步降低成本。 #### 四、设计原则 针对这些目标,报告还提出了一套设计...

Global site tag (gtag.js) - Google Analytics