15 releases

0.2.10 Jun 23, 2020
0.2.9 Jun 8, 2020
0.2.7 May 26, 2020
0.2.3 Mar 8, 2020
0.1.1 Sep 3, 2018

#112 in Asynchronous

Download history 230/week @ 2021-02-26 87/week @ 2021-03-05 8/week @ 2021-03-12 66/week @ 2021-03-19 285/week @ 2021-03-26 268/week @ 2021-04-02 65/week @ 2021-04-09 64/week @ 2021-04-16 119/week @ 2021-04-23 40/week @ 2021-04-30 27/week @ 2021-05-07 53/week @ 2021-05-14 29/week @ 2021-05-21 24/week @ 2021-05-28 29/week @ 2021-06-04 24/week @ 2021-06-11

450 downloads per month
Used in 4 crates (via v-common-storage)

Apache-2.0

60KB
1.5K SLoC

Simple Rust client to tarantool

Ported java connector to tarantool db

https://tarantool.io

https://github.com/tarantool/tarantool-java

Overview

Use tokio.io as base client framework

Usage

Latest Version

Example

Call echo stored procedure

run tarantool

cd test-tarantool;tarantool init-tarantool.lua

Lua stored procedure:

function test(a,b)
   return a,b,11
end

Rust client :


println!("Connect to tarantool and call simple stored procedure!");
let client = ClientConfig::new("127.0.0.1:3301", "rust", "rust")
                     .set_timeout_time_ms(2000)
                     .set_reconnect_time_ms(2000)
                     .build();

let response = client
    .prepare_fn_call("test")
    .bind_ref(&("aa", "aa"))?
    .bind(1)?
    .execute().await?;
let res: ((String,String), u64) = response.decode_pair()?;
println!("stored procedure response ={:?}", res);

let response_sql = client
    .prepare_sql("select * from TABLE1 where COLUMN1=?")
    .bind(1)?
    .execute().await?;
    let meta = response.metadata();
    let rows: Vec<(u32, String)> = response.decode_result_set()?;
    println!("resp value={:?}", row);

Output :

Connect to tarantool and call simple stored procedure!
stored procedure response =(("param11", "param12"), (2,), (Some(11),))

On examples part of project you can also see more complicated examples :

hyper http server connecting to tarantool

actix-web example

simple benchmark

Dependencies

~7MB
~144K SLoC