mimir 0.3.5

Rust bindings over the Oracle Database Programming Interface for Drivers and Applications
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
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77

use mimir::enums::ODPIDeqMode::{Browse, Remove};
use mimir::enums::ODPIDeqNavigation::{FirstMsg, NextMsg};
use mimir::enums::ODPIVisibility::{Immediate, OnCommit};
use mimir::flags;
use mimir::Connection;
use mimir::Context;
use mimir::Result;
use CREDS;

fn dequeue_res(ctxt: &Context) -> Result<()> {
    let mut common_create_params = ctxt.init_common_create_params()?;
    common_create_params.set_encoding("UTF-8")?;
    common_create_params.set_nchar_encoding("UTF-8")?;
    common_create_params.set_create_mode(flags::DPI_MODE_CREATE_EVENTS);

    let mut common_connection_params = ctxt.init_conn_create_params()?;
    common_connection_params.set_auth_mode(flags::DPI_MODE_AUTH_DEFAULT);

    let conn = Connection::create(
        ctxt,
        Some(&CREDS[0]),
        Some(&CREDS[1]),
        Some("//oic.cbsnae86d3iv.us-east-2.rds.amazonaws.com/ORCL"),
        Some(common_create_params),
        Some(common_connection_params),
    )?;

    let dequeue_opts = conn.new_deq_options()?;

    dequeue_opts.set_consumer_name(Some("jozias"))?;
    let consumer_name = dequeue_opts.get_consumer_name()?;
    assert_eq!(consumer_name, "jozias");

    dequeue_opts.set_correlation(Some("joz%"))?;
    let correlation = dequeue_opts.get_correlation()?;
    assert_eq!(correlation, "joz%");

    dequeue_opts.set_msg_id(Some("uno"))?;
    // TODO: Fix get_msg_id (causes SIGSEV)
    // let msg_id = dequeue_opts.get_msg_id()?;
    // assert_eq!(msg_id, "uno");

    dequeue_opts.set_wait(100_000)?;
    let wait = dequeue_opts.get_wait()?;
    assert_eq!(wait, 100_000);

    dequeue_opts.set_transformation(Some("tsfm"))?;
    let transformation = dequeue_opts.get_transformation()?;
    assert_eq!(transformation, "tsfm");

    let mut visibility = dequeue_opts.get_visibility()?;
    assert_eq!(visibility, OnCommit);
    dequeue_opts.set_visibility(Immediate)?;
    visibility = dequeue_opts.get_visibility()?;
    assert_eq!(visibility, Immediate);

    let mut mode = dequeue_opts.get_mode()?;
    assert_eq!(mode, Remove);
    dequeue_opts.set_mode(Browse)?;
    mode = dequeue_opts.get_mode()?;
    assert_eq!(mode, Browse);

    let mut nav = dequeue_opts.get_navigation()?;
    assert_eq!(nav, NextMsg);
    dequeue_opts.set_navigation(FirstMsg)?;
    nav = dequeue_opts.get_navigation()?;
    assert_eq!(nav, FirstMsg);

    conn.close(flags::DPI_MODE_CONN_CLOSE_DEFAULT, None)?;

    Ok(())
}

#[test]
fn dequeue() {
    check_with_ctxt!(dequeue_res)
}