[openresty] drizzle 在ngx.location.capture中如何使用事务处理机制

yuting · 2014-11-11T10:27:00+00:00

wgetOn Tue Nov 11 2014 at 上午10:37:43 <xiati...@gmail.com> wrote:你好，我看了你的库&...

[openresty] drizzle 在ngx.location.capture中如何使用事务处理机制

yuting

大家好

我是新手我想请教个问题谢谢。

drizzle 的配置是:

    upstream backend {
         drizzle_server localhost:3306 dbname=todo
         password=root user=root protocol=mysql charset=utf8;
    }

    location /mysql {
          internal;
          drizzle_pass backend;
          drizzle_module_header off;
          #drizzle_query drizzle_process($request_body);
          drizzle_query $request_body;
          drizzle_connect_timeout    5s;    # 500ms; # default 60s
          drizzle_send_query_timeout 2s;    # default 60s
          drizzle_recv_cols_timeout 1s;    # default 60s
          drizzle_recv_rows_timeout 1s;    # default 60s
          rds_json on;
     }

这个配置是正确的

     我在lua 中使用
     test = function(sql,...)
         local res = ngx.location.capture("/mysql",{method=ngx.HTTP_POST,body=format(sql,...)})
       return util.decode(res.body)

end

测试事务代码:

test("START TRANSACTION;")

对表test进行插入数据

test("insert into test values(NULL)");

test("commit;") //这里我并没有设置 set autocommit = 0 因为每次使用都不起效。

如果这里使用 test("rollback;") 也没有回滚的效果

但是以上几句在mysql 同一个查询中是有效的。

请问 drizzle 该如何正确使用事务，谢谢

smallfish.xy

需要这种事务处理的话建议直接封装成『存储过程』（lua-resty-mysql）来解决吧。

On Tue Nov 11 2014 at 上午10:27:01 yuting <yu...@sh-tpa.com> wrote:

大家好

    我是新手我想请教个问题谢谢。

    drizzle 的配置是:

    upstream backend {
         drizzle_server localhost:3306 dbname=todo
         password=root user=root protocol=mysql charset=utf8;
    }

    location /mysql {
          internal;
          drizzle_pass backend;
          drizzle_module_header off;
          #drizzle_query drizzle_process($request_body);
          drizzle_query $request_body;
          drizzle_connect_timeout    5s;    # 500ms; # default 60s
          drizzle_send_query_timeout 2s;    # default 60s
          drizzle_recv_cols_timeout 1s;    # default 60s
          drizzle_recv_rows_timeout 1s;    # default 60s
          rds_json on;
     }

     这个配置是正确的

     我在lua 中使用
     test = function(sql,...)
         local res = ngx.location.capture("/mysql",{method=ngx.HTTP_POST,body=format(sql,...)})
       return util.decode(res.body)

     end



     测试事务代码:



     test("START TRANSACTION;")

     对表test进行插入数据



     test("insert into test values(NULL)");

     test("commit;")    //这里我并没有设置 set autocommit = 0 因为每次使用都不起效。

     如果这里使用 test("rollback;") 也没有回滚的效果



     但是以上几句在mysql 同一个查询中是有效的。

     请问 drizzle 该如何正确使用事务，谢谢

--

--

yuting

能给点具体方式么？谢谢

2014-11-11

yuting

发件人：smallfish <small...@gmail.com>

发送时间：2014-11-11 11:20

主题：Re: [openresty] drizzle 在ngx.location.capture中如何使用事务处理机制

收件人："openresty"<openresty@googlegroups.com>

抄送：

需要这种事务处理的话建议直接封装成『存储过程』（lua-resty-mysql）来解决吧。

On Tue Nov 11 2014 at 上午10:27:01 yuting <yu...@sh-tpa.com> wrote:

大家好

    我是新手我想请教个问题谢谢。

    drizzle 的配置是:

    upstream backend {
         drizzle_server localhost:3306 dbname=todo
         password=root user=root protocol=mysql charset=utf8;
    }

    location /mysql {
          internal;
          drizzle_pass backend;
          drizzle_module_header off;
          #drizzle_query drizzle_process($request_body);
          drizzle_query $request_body;
          drizzle_connect_timeout    5s;    # 500ms; # default 60s
          drizzle_send_query_timeout 2s;    # default 60s
          drizzle_recv_cols_timeout 1s;    # default 60s
          drizzle_recv_rows_timeout 1s;    # default 60s
          rds_json on;
     }

     这个配置是正确的

     我在lua 中使用
     test = function(sql,...)
         local res = ngx.location.capture("/mysql",{method=ngx.HTTP_POST,body=format(sql,...)})
       return util.decode(res.body)

     end



     测试事务代码:



     test("START TRANSACTION;")

     对表test进行插入数据



     test("insert into test values(NULL)");

     test("commit;")    //这里我并没有设置 set autocommit = 0 因为每次使用都不起效。

     如果这里使用 test("rollback;") 也没有回滚的效果



     但是以上几句在mysql 同一个查询中是有效的。

     请问 drizzle 该如何正确使用事务，谢谢

--

--

yuting

好吧我认了还是用 lua-resty-mysql 来实现谢谢额

那如果这样的话 drizzle 从数据保护方面还是不适合用的么？

2014-11-11

yuting

发件人："yuting" <yu...@sh-tpa.com>

发送时间：2014-11-11 11:24

主题：回复: Re: [openresty] drizzle 在ngx.location.capture中如何使用事务处理机制

收件人："openresty"<openresty@googlegroups.com>

抄送：

能给点具体方式么？谢谢

2014-11-11

yuting

发件人：smallfish <small...@gmail.com>

发送时间：2014-11-11 11:20

主题：Re: [openresty] drizzle 在ngx.location.capture中如何使用事务处理机制

收件人："openresty"<openresty@googlegroups.com>

抄送：

需要这种事务处理的话建议直接封装成『存储过程』（lua-resty-mysql）来解决吧。

On Tue Nov 11 2014 at 上午10:27:01 yuting <yu...@sh-tpa.com> wrote:

大家好

    我是新手我想请教个问题谢谢。

    drizzle 的配置是:

    upstream backend {
         drizzle_server localhost:3306 dbname=todo
         password=root user=root protocol=mysql charset=utf8;
    }

    location /mysql {
          internal;
          drizzle_pass backend;
          drizzle_module_header off;
          #drizzle_query drizzle_process($request_body);
          drizzle_query $request_body;
          drizzle_connect_timeout    5s;    # 500ms; # default 60s
          drizzle_send_query_timeout 2s;    # default 60s
          drizzle_recv_cols_timeout 1s;    # default 60s
          drizzle_recv_rows_timeout 1s;    # default 60s
          rds_json on;
     }

     这个配置是正确的

     我在lua 中使用
     test = function(sql,...)
         local res = ngx.location.capture("/mysql",{method=ngx.HTTP_POST,body=format(sql,...)})
       return util.decode(res.body)

     end



     测试事务代码:



     test("START TRANSACTION;")

     对表test进行插入数据



     test("insert into test values(NULL)");

     test("commit;")    //这里我并没有设置 set autocommit = 0 因为每次使用都不起效。

     如果这里使用 test("rollback;") 也没有回滚的效果



     但是以上几句在mysql 同一个查询中是有效的。

     请问 drizzle 该如何正确使用事务，谢谢

--

--

yuting

谢谢，smallfish ，总算弄明白了我还回顾了下前周的邮件发现

用lua-resty-mysql 处理 insert update delete

用drizzle 处理获取数据

lua-resty-mysql 在消耗上比 drizzle 更大所以我决定用两种模式处理数据，谢谢

2014-11-11

yuting

发件人：smallfish <small...@gmail.com>

发送时间：2014-11-11 11:20

主题：Re: [openresty] drizzle 在ngx.location.capture中如何使用事务处理机制

收件人："openresty"<openresty@googlegroups.com>

抄送：

需要这种事务处理的话建议直接封装成『存储过程』（lua-resty-mysql）来解决吧。

On Tue Nov 11 2014 at 上午10:27:01 yuting <yu...@sh-tpa.com> wrote:

大家好

    我是新手我想请教个问题谢谢。

    drizzle 的配置是:

    upstream backend {
         drizzle_server localhost:3306 dbname=todo
         password=root user=root protocol=mysql charset=utf8;
    }

    location /mysql {
          internal;
          drizzle_pass backend;
          drizzle_module_header off;
          #drizzle_query drizzle_process($request_body);
          drizzle_query $request_body;
          drizzle_connect_timeout    5s;    # 500ms; # default 60s
          drizzle_send_query_timeout 2s;    # default 60s
          drizzle_recv_cols_timeout 1s;    # default 60s
          drizzle_recv_rows_timeout 1s;    # default 60s
          rds_json on;
     }

     这个配置是正确的

     我在lua 中使用
     test = function(sql,...)
         local res = ngx.location.capture("/mysql",{method=ngx.HTTP_POST,body=format(sql,...)})
       return util.decode(res.body)

     end



     测试事务代码:



     test("START TRANSACTION;")

     对表test进行插入数据



     test("insert into test values(NULL)");

     test("commit;")    //这里我并没有设置 set autocommit = 0 因为每次使用都不起效。

     如果这里使用 test("rollback;") 也没有回滚的效果



     但是以上几句在mysql 同一个查询中是有效的。

     请问 drizzle 该如何正确使用事务，谢谢

--

--

agentzh

Hello!

2014-11-10 18:27 GMT-08:00 yuting:
>      test("insert into test values(NULL)");
>      test("commit;")    //这里我并没有设置 set autocommit = 0 因为 每次使用都不起效。
>      如果这里使用 test("rollback;") 也没有回滚的效果
>      但是以上几句 在mysql 同一个查询中是有效的。
>

ngx_drizzle 模块并不支持这种跨（子）请求的事务，因为你无法确保前后不同请求之间使用的是同一个 mysql 连接。

使用 lua-resty-mysql 库是推荐的做法。

Regards,
-agentzh