forked from jkvor/emysql
-
Notifications
You must be signed in to change notification settings - Fork 208
/
e_stored_procedure.erl
101 lines (91 loc) · 3.13 KB
/
e_stored_procedure.erl
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
% ------------------------------------------------------------------------
% Emysql: Stored procedure, a minimal sample
% H. Diedrich <[email protected]> - Eonblast http://www.eonblast.com
% 12 Jun 2010
% Thanks to Seven Du <https://github.com/seven1240>
% ------------------------------------------------------------------------
%
% Create local mysql database (or re-use the one made for a_hello):
%
% $ mysql ...
% mysql> create database hello_database;
% mysql> use hello_database;
% mysql> create table hello_table (hello_text char(20));
% mysql> grant all privileges on hello_database.* to hello_username@localhost identified by 'hello_password';
% mysql> quit
%
% On *nix build and run using the batch e_stored_procedure in folder samples/:
%
% $ ./e_stored_procedure
%
% - or -
%
% Make emysql and start this sample directly, along these lines:
%
% $ cd Emysql
% $ make
% $ cd samples
% $ erlc e_stored_procedure.erl
% $ erl -pa ../ebin -s e_stored_procedure run -s init stop -noshell
%
% ------------------------------------------------------------------------
%
% Expected Output: (note the result being a list, and the final ok_package)
%
% Connect
% -------
%
% Create Record
% -------------
%
% Test Select
% -----------
% {result_packet,6,
% [{field,2,<<"def">>,<<"hello_database">>,<<"hello_table">>,
% <<"hello_table">>,<<"hello_text">>,<<"hello_text">>,
% 254,<<>>,33,60,0,0}],
% [[<<"Hello World!">>],[<<"Hello World!">>]],
% <<>>}
%
% Create Stored Procedure
% -----------------------
% {ok_packet,1,0,0,2,0,[]}
%
% Call Stored Procedure
% ---------------------
% [{result_packet,6,
% [{field,2,<<"def">>,<<"hello_database">>,<<"hello_table">>,
% <<"hello_table">>,<<"hello_text">>,<<"hello_text">>,
% 254,<<>>,33,60,0,0}],
% [[<<"Hello World!">>],[<<"Hello World!">>]],
% <<>>},
% {ok_packet,7,0,0,34,0,[]}]
% %
% ------------------------------------------------------------------------
-module(e_stored_procedure).
-export([run/0]).
run() ->
crypto:start(),
application:start(emysql),
io:format("~nConnect~n-------~n", []),
emysql:add_pool(hello_pool, [{size,1},
{user,"hello_username"},
{password,"hello_password"},
{database,"hello_database"},
{encoding,utf8}]),
io:format("~nCreate Record~n-------------~n", []),
emysql:execute(hello_pool,
<<"INSERT INTO hello_table SET hello_text = 'Hello World!'">>),
io:format("~nTest Select~n-----------~n", []),
Result1 = emysql:execute(hello_pool,
<<"select * from hello_table limit 2">>),
io:format("~p~n", [Result1]),
io:format("~nCreate Stored Procedure~n-----------------------~n", []),
Result2 = emysql:execute(hello_pool,
<<"create procedure sp_hello() begin select * from hello_table limit 2; end">>),
io:format("~p~n", [Result2]),
io:format("~nCall Stored Procedure~n---------------------~n", []),
Result3 = emysql:execute(hello_pool,
<<"call sp_hello();">>),
io:format("~p~n", [Result3]),
done.