erlang连接到mysql数据库

dxm1986

浏览: 435239 次
性别:
来自: 北京

最近访客更多访客>>

cat_rat

Peak_

liujickson

孙宜锋

博主相关

博客

微博

相册

留言

关于我

文章分类

社区版块

存档分类

博客分类：

erlang

MySQL Erlang SVN

erlang连接到mysql数据库

一，驱动的下载与安装

1. 下载erlang-mysql-driver

下载地址如下：

svn checkout http://erlang-mysql-driver.googlecode.com/svn/trunk/ mysql

(如果你没有安装SVN，附件中提供源码下载)

2. 对src下面的所有源码进行编译

erlc *.erl

3. 然后在mysql 下面创建ebin，并将src 下面的所有*.beam拷贝到ebin 下面

4. 将mysql整个文件夹拷贝到erlang/lib下面

二， 操作数据库

1 连接mysql:

mysql:start_link(PoolId, "localhost", "root", "password", "databasename").

2 mysql:connect(PoolId, Host, ?PORT, User, Password, Database, undefined,

Reconnect).%%建立一个连接

3 数据操作

添加：

mysql:fetch(PoolId,<<”insert into….”>>).

查询：

mysql:fetch(p1,<<"select * from user">>).

4 接收到数据后怎么处理

fetch(PoolId, "select * from user") -> Result

%%% Result = {data, MySQLRes} | {updated, MySQLRes} |

%%% {error, MySQLRes}

n 查询：{data, MySQLRes} = fetch(PoolId, <<"select * from user">>).

Ø 获取字段名称信息:

FieldInfo = mysql:get_result_field_info(MysqlRes).

Ø 获取字段值：

AllRows = mysql:get_result_rows(MysqlRes)

n 更新:

{updated,UD} = mysql: fetch(PoolId, <<"update * from user">>).

AffectedRow = mysql:get_result_affected_rows(UD).%%获得影响的记录数

n 出错

{error,Err} = fetch(PoolId, <<"update * from user">>).

Reason = mysql:get_result_reason(MysqlRes).%%出错原因

erlang-mysql-driver-read-only.rar (46.4 KB)
下载次数: 139

分享到：

Linux操作系统下三种配置环境变量的方法 | linux下odbc安装

2011-02-18 14:11
浏览 4551
评论(1)
论坛回复 / 浏览 (1 / 9239)
分类:编程语言
查看更多

1 楼 developerworks 2011-05-22

<div class="quote_title">dxm1986 写道</div><div class="quote_div">erlang连接到mysql数据库
 
 
一，驱动的下载与安装
 
1.
下载erlang-mysql-driver
 下载地址如下：
 svn checkout http://erlang-mysql-driver.googlecode.com/svn/trunk/
 mysql
 (如果你没有安装SVN，附件中提供源码下载)
2.
 对src下面的所有源码进行编译
 erlc *.erl
 
3.
 然后在mysql 下面创建ebin，并将src 下面的所有*.beam拷贝到ebin 下面
4.
 将mysql整个文件夹拷贝到erlang/lib下面
 
二，
操作数据库
1
连接mysql:
mysql:start_link(PoolId,
"localhost", "root", "password", "databasename").
 
 2 mysql:connect(PoolId,
Host, ?PORT, User, Password, Database, undefined,
 
Reconnect).%%建立一个连接
 
3 数据操作
 添加：
mysql:fetch(PoolId,<<”insert into….”>>).
 查询：
mysql:fetch(p1,<<"select * from
user">>).
 


4 接收到数据后怎么处理
 fetch(PoolId,
"select * from user") -> Result
 %%% Result = {data, MySQLRes} | {updated,
MySQLRes} |
 %%% {error, MySQLRes}
 
n 查询：{data,
MySQLRes} = fetch(PoolId, <<"select * from user">>).
Ø 获取字段名称信息:
 
FieldInfo = mysql:get_result_field_info(MysqlRes).
Ø 获取字段值：
 
AllRows =
mysql:get_result_rows(MysqlRes)
 
n 更新:
{updated,UD} = mysql: fetch(PoolId, <<"update
 * from user">>).
 
 AffectedRow = mysql:get_result_affected_rows(UD).%%获得影响的记录数
 
n 出错
{error,Err} = fetch(PoolId, <<"update
 * from user">>).
Reason = mysql:get_result_reason(MysqlRes).%%出错原因
</div> 注意mysql:start_link的第八个参数encoding,设置为utf8,以支持中文

发表评论

您还没有登录,请您登录后再发表评论

最近访客更多访客>>

博主相关

文章分类

社区版块

存档分类

最新评论