manticoresearch 2.0.0

Сlient for Manticore Search.
Documentation 
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

use std::sync::Arc;
use manticoresearch::{apis::configuration::Configuration, apis::UtilsApi, apis::UtilsApiClient, models::SqlResponse};

use tokio;


#[tokio::test]
async fn utils_api_basic_requests() {
    let api_config = Arc::new(Configuration::new());
    let utils_api = UtilsApiClient::new(api_config);

    // DROP TABLE IF EXISTS
    let res = utils_api.sql("DROP TABLE IF EXISTS products", Some(true)).await;
    assert!(res.is_ok(), "DROP TABLE failed: {:?}", res.err());

    // CREATE TABLE
    let create_query = "CREATE TABLE IF NOT EXISTS products (title text, price float, sizes multi, meta json, coeff float, tags1 multi, tags2 multi)";
    let res = utils_api.sql(create_query, Some(true)).await;
    assert!(res.is_ok(), "CREATE TABLE failed: {:?}", res.err());

    // SELECT with parse=true
    let res = utils_api.sql("SELECT * FROM products", Some(true)).await;
    assert!(res.is_ok(), "SELECT (parse=true) failed: {:?}", res.err());

    // SELECT with parse=false
    let res = utils_api.sql("SELECT * FROM products", Some(false)).await;
    assert!(res.is_ok(), "SELECT (parse=false) failed: {:?}", res.err());

    // SHOW TABLES
    let res = utils_api.sql("SHOW TABLES", Some(true)).await;
    assert!(res.is_ok(), "SHOW TABLES failed: {:?}", res.err());

    let result = res.unwrap();
    let is_arr_response = matches!(result, SqlResponse::SqlRawResponse { .. });
    assert!(is_arr_response == true);

    if let SqlResponse::SqlRawResponse(objs) = result {
        println!("value: {:#?}", objs[0]);
    }
}