需要用到一個名為Erlang-MySQL-Driver的開源項目,點這裏去項目主頁~~
創建並打開第一個MySQL連接(pl為連接池標識):
mysql:start_link(pl,”localhost”,”user”,”password”,”database”).
可繼續添加連接到連接池:
mysql:connect(pl,”localhost”,undefined,”user”,”password”,”database”,true).
執行SQL語句:
mysql:fetch(pl,<<”insert into table ….”>>),
Result=mysql:fetch(pl,<<”select * from table ….”>>),
io:format(”Result : ~p\n”,[Result]).
處理返回結果:
執行語句後的返回結果有如下三種類型:
{data,MySQLRes}, {update,MySQLRes}, {error,MySQLRes}
MySQLRes為mysql_result類型的record數據(mysql_result定義與mysql.hrl文件中),其具體結構如下:
{mysql_result, [fieldinfo], [rows], affectedrows, [error]}
fieldinfo:域信息,包括域所屬表、域名、數據長度、數據類型;
rows:實際數據;
affectedrows:執行SQL語句影響的行數;
error:錯誤信息。
Erlang-mysql-driver還包括事務等其他功能,具體可以查看下載包裏的例子。
0 意見