erlang连接到mysql数据库

by

at 2011-02-18 14:11:11

original http://www.javaeye.com/topic/910030

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).%%出错原因

  <li><a href="http://dl.javaeye.com/topics/download/800eb6be-6370-3bcf-b942-d128713d0855">erlang-mysql-driver-read-only.rar</a> (46.4 KB)</li>

      <br><br>
      作者: <a href="http://wolfdream.javaeye.com">dxm1986</a> 
      <br>
      声明: 本文系JavaEye网站发布的原创文章，未经作者书面许可，严禁任何网站转载本文，否则必将追究法律责任！
      <br><br>
      <span style="color:red">
        <a href="http://www.javaeye.com/topic/910030" style="color:red">已有 <strong>0</strong> 人发表回复，猛击-&gt;&gt;<strong>这里</strong>&lt;&lt;-参与讨论</a>
      </span>
      <br><br><br>

JavaEye推荐

—软件人才免语言低担保赴美带薪读研！—

Google Reader