asyncmysql's Introduction

AsyncMysql

AsyncMysql is an asynchronous (None-Blocking) MySQL connector written in pure Nim.

Features

execute multiple SQL statements in a single query
streaming large result sets
commit and rollback transaction
connection pool

Examples

type
  Replies = seq[tuple[packet: ResultPacket, rows: seq[string]]]

proc execMyQuery(pool: AsyncMysqlPool, q: SqlQuery): Future[Replies] =
  var retFuture = newFuture[void]("execMyQuery")
  result = retFuture

  proc finishCb(err: ref Exception, replies: Replies) {.async.} =
    if err == nil:
      complete(retFuture, replies)
    else:
      fail(retFuture, err)

  execQuery(pool, q, finishCb)

proc main() {.async.} =
  let pool = await openMysqlPool(domain=AF_INET, 
                                 port=Port(3306), 
                                 host="127.0.0.1", 
                                 user="mysql", 
                                 password="123456", 
                                 database="mysql", 
                                 capacity=10)
  let query = sql("""
start transaction;
select host, user from user where user = ?;
select user from user;
commit;
""", "root")
  let replies = await pool.execMyQuery(query)

  echo ">> start transaction;"
  assert replies[0].packet.kind = rpkOk 

  echo ">> select host, user from user where user = ?;"
  assert replies[1].packet.kind = rpkResultSet
  echo replies[1].rows 

  echo ">> select user from user;"
  assert replies[2].packet.kind = rpkResultSet
  echo replies[2].rows 

  echo ">> commit;"
  assert replies[3].packet.kind = rpkOk

  pool.close()