mirror https://github.com/mysql-otp/mysql-otp

Viktor Söderqvist 2b51002a40 Avoid dict:is_empty/1 for compat with old OTP versions 10 years ago
doc ec7353a978 Merges mysql_connection with mysql 10 years ago
include 5f057dda27 Implements selecting db in the connection phase 10 years ago
src 2b51002a40 Avoid dict:is_empty/1 for compat with old OTP versions 10 years ago
test db2191db31 Parametrized queries using cached prep. stmts 10 years ago
.gitignore e2e7e66375 EDoc overview page and custom CSS 10 years ago
.travis.yml 576d3ff111 Set up Travis build 10 years ago
COPYING f9d921a9c3 Change license to LGPL 10 years ago
COPYING.LESSER f9d921a9c3 Change license to LGPL 10 years ago
Makefile a638874736 Makefile rules for gh-pages 10 years ago
README.md db405ed5fd Add parametrized queries to README 10 years ago
rebar.config e2e7e66375 EDoc overview page and custom CSS 10 years ago

README.md

MySQL/OTP

Build Status

MySQL/OTP is a client library for connecting to MySQL databases from Erlang/OTP applications. It is a native implementation of the MySQL protocol in Erlang.

Features:

  • Mnesia style transactions. (Currenly transactions cannot be nested and are not retried automatically when deadlocks are detected. These are features of Mnesia style transactions and there are plans to implement them. See #7.)
  • Uses the binary protocol for prepared statements.
  • Each connection is a gen_server, which makes it compatible with Poolboy (for connection pooling) and ordinary OTP supervisors.
  • No records in the public API.

See also:

This is a work in progress. The API and the value representation may still change. Use a tagged version to make sure nothing breaks.

Synopsis

Opts = [{host, "localhost"}, {user, "foo"}, {password, "hello"},
        {database, "test"}],

%% Connect
{ok, Pid} = mysql:start_link(Opts),

%% Select
{ok, ColumnNames, Rows} =
    mysql:query(Pid, <<"SELECT * FROM mytable WHERE id = ?">>, [1]),

%% Manipulate data
ok = mysql:query(Pid, "INSERT INTO mytable (id, bar) VALUES (?, ?)", [1, 42]),

%% Separate calls to fetch more info about the last query
LastInsertId = mysql:insert_id(Pid),
AffectedRows = mysql:affected_rows(Pid),
WarningCount = mysql:warning_count(Pid),

%% Mnesia style transaction
Result = mysql:transaction(Pid, fun () ->
    ok = mysql:query(Pid, "INSERT INTO mytable (foo) VALUES (1)"),
    throw(foo),
    ok = mysql:query(Pid, "INSERT INTO mytable (foo) VALUES (1)")
end),
case Result of
    {atomic, ResultOfFun} ->
        io:format("Inserted 2 rows.~n");
    {aborted, Reason} ->
        io:format("Inserted 0 rows.~n")
end

Tests

Run the eunit tests with rebar eunit. For the suite mysql_tests you need MySQL running on localhost and give privileges to the otptest user:

grant all privileges on otptest.* to otptest@localhost identified by 'otptest';

Contributing

Pull request and feature requests are welcome. If you're looking for something to do, pick one of the issues and solve it. Remember to include test cases.

License

GNU Lesser General Public License (LGPL) version 3 or any later version. Since the LGPL is a set of additional permissions on top of the GPL, both license texts are included in the files COPYING and COPYING.LESSER respectively.

We hope this license should be permissive enough while remaining copyleft. If you're having issues with this license, please create an issue in the issue tracker!