couchbase 0.3.0

The Couchbase Rust SDK
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

extern crate couchbase;
extern crate futures;

use couchbase::{Cluster, N1qlResult};
use futures::Stream;

/// Opens a bucket and then runs a N1QL query and prints out the results.
fn main() {
    // Initialize the Cluster
    let cluster = Cluster::new("localhost").expect("Could not initialize Cluster");

    // Open the travel-sample bucket
    let bucket = cluster
        .open_bucket("travel-sample", None)
        .expect("Could not open Bucket");

    // Run the query and iterate the rows.
    for row in bucket
        .query_n1ql("SELECT count(*) as cnt FROM `travel-sample`")
        .wait()
    {
        match row {
            Ok(N1qlResult::Row(r)) => println!("Found Row {:?}", r),
            Ok(N1qlResult::Meta(m)) => println!("Found Meta {:?}", m),
            Err(e) => panic!("Error! {:?}", e),
        }
    }
}