History

Shawn bea5966ac8 fix(emqx_connector): remove unrelated files and add license headers		2021-06-02 19:10:24 +08:00
..
etc	feat(emqx_resource): read and save configs from and to file	2021-06-02 01:58:32 +08:00
priv	fix(emqx_connector): start emqx_connector_mysql failed	2021-06-02 17:28:47 +08:00
src	fix(emqx_connector): remove unrelated files and add license headers	2021-06-02 19:10:24 +08:00
.gitignore	feat(emqx_connector): add first emqx_connector for mysql	2021-05-31 15:14:07 +08:00
README.md	fix(emqx_connector): remove unrelated files and add license headers	2021-06-02 19:10:24 +08:00
rebar.config	feat(emqx_connector): add first emqx_connector for mysql	2021-05-31 15:14:07 +08:00

README.md

emqx_connector

A connector is an object that maintains the data related to external resources.

For example, a mysql connector is an object that maintains all the mysql connection related parameters (configs) and the TCP connections to the mysql server.

An mysql connector can be used as following:

(emqx@127.0.0.1)5> emqx_resource:list_instances_verbose().
[#{config =>
       #{auto_reconnect => true,cacertfile => [],certfile => [],
         database => "mqtt",keyfile => [],password => "public",
         pool_size => 1,
         server => {{127,0,0,1},3306},
         ssl => false,user => "root",verify => false},
   id => <<"mysql-abc">>,mod => emqx_connector_mysql,
   state => #{poolname => 'mysql-abc'},
   status => started}]
(emqx@127.0.0.1)6> emqx_resource:query(<<"mysql-abc">>, {sql, <<"SELECT count(1)">>}).
{ok,[<<"count(1)">>],[[1]]}