fluencelabs/sqlite-wasm-connector
1
0
Fork 0
mirror of https://github.com/fluencelabs/sqlite-wasm-connector synced 2025-04-25 16:52:15 +00:00
Code Issues Projects Releases Wiki Activity

Let the benchmarks work with four columns

Browse Source
This commit is contained in:
Ivan Ukhov 2015-12-21 16:51:44 +01:00
parent 8be28b9272
commit a157cf36b2
1 changed files with 47 additions and 38 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

85
benches/lib.rs
View File

@ -3,22 +3,25 @@
extern crate sqlite; extern crate sqlite;
extern crate test; extern crate test;
use sqlite::{Connection, State, Value}; use sqlite::Value::{Float, Integer};
use sqlite::{Connection, State};
use test::Bencher; use test::Bencher;
macro_rules! ok(($result:expr) => ($result.unwrap()));
#[bench] #[bench]
fn read_cursor(bencher: &mut Bencher) { fn read_cursor(bencher: &mut Bencher) {
let connection = create(); let connection = create();
populate(&connection, 100); populate(&connection, 100);
let mut cursor = connection.prepare(" let mut cursor = ok!(connection.prepare("
SELECT * FROM data WHERE integer > ? AND real > ? SELECT * FROM data WHERE a > ? AND b > ?
").unwrap().cursor(); ")).cursor();
bencher.iter(|| { bencher.iter(|| {
cursor.bind(&[Value::Integer(42), Value::Float(69.0)]).unwrap(); ok!(cursor.bind(&[Integer(42), Float(42.0)]));
while let Some(row) = cursor.next().unwrap() { while let Some(row) = ok!(cursor.next()) {
assert!(row[0].as_integer().unwrap() > 42); assert!(ok!(row[0].as_integer()) > 42);
assert!(row[1].as_float().unwrap() > 69.0); assert!(ok!(row[1].as_float()) > 42.0);
} }
}) })
} }
@ -27,17 +30,17 @@ fn read_cursor(bencher: &mut Bencher) {
fn read_statement(bencher: &mut Bencher) { fn read_statement(bencher: &mut Bencher) {
let connection = create(); let connection = create();
populate(&connection, 100); populate(&connection, 100);
let mut statement = connection.prepare(" let mut statement = ok!(connection.prepare("
SELECT * FROM data WHERE integer > ? AND real > ? SELECT * FROM data WHERE a > ? AND b > ?
").unwrap(); "));
bencher.iter(|| { bencher.iter(|| {
statement.reset().unwrap(); ok!(statement.reset());
statement.bind(1, 42).unwrap(); ok!(statement.bind(1, 42));
statement.bind(2, 69.0).unwrap(); ok!(statement.bind(2, 42.0));
while let State::Row = statement.next().unwrap() { while let State::Row = ok!(statement.next()) {
assert!(statement.read::<i64>(0).unwrap() > 42); assert!(ok!(statement.read::<i64>(0)) > 42);
assert!(statement.read::<f64>(1).unwrap() > 69.0); assert!(ok!(statement.read::<f64>(1)) > 42.0);
} }
}) })
} }
@ -45,45 +48,51 @@ fn read_statement(bencher: &mut Bencher) {
#[bench] #[bench]
fn write_cursor(bencher: &mut Bencher) { fn write_cursor(bencher: &mut Bencher) {
let connection = create(); let connection = create();
let mut cursor = connection.prepare(" let mut cursor = ok!(connection.prepare("
INSERT INTO data (integer, real) VALUES (?, ?) INSERT INTO data (a, b, c, d) VALUES (?, ?, ?, ?)
").unwrap().cursor(); ")).cursor();
bencher.iter(|| { bencher.iter(|| {
cursor.bind(&[Value::Integer(42), Value::Float(69.0)]).unwrap(); ok!(cursor.bind(&[Integer(42), Float(42.0), Float(42.0), Float(42.0)]));
cursor.next().unwrap(); ok!(cursor.next());
}) })
} }
#[bench] #[bench]
fn write_statement(bencher: &mut Bencher) { fn write_statement(bencher: &mut Bencher) {
let connection = create(); let connection = create();
let mut statement = connection.prepare(" let mut statement = ok!(connection.prepare("
INSERT INTO data (integer, real) VALUES (?, ?) INSERT INTO data (a, b, c, d) VALUES (?, ?, ?, ?)
").unwrap(); "));
bencher.iter(|| { bencher.iter(|| {
statement.reset().unwrap(); ok!(statement.reset());
statement.bind(1, 42).unwrap(); ok!(statement.bind(1, 42));
statement.bind(2, 69.0).unwrap(); ok!(statement.bind(2, 42.0));
assert_eq!(statement.next().unwrap(), State::Done); ok!(statement.bind(3, 42.0));
ok!(statement.bind(4, 42.0));
assert_eq!(ok!(statement.next()), State::Done);
}) })
} }
fn create() -> Connection { fn create() -> Connection {
let connection = Connection::open(":memory:").unwrap(); let connection = ok!(Connection::open(":memory:"));
connection.execute("CREATE TABLE data (integer INTEGER, real REAL)").unwrap(); ok!(connection.execute("
CREATE TABLE data (a INTEGER, b REAL, c REAL, d REAL)
"));
connection connection
} }
fn populate(connection: &Connection, count: usize) { fn populate(connection: &Connection, count: usize) {
let mut statement = connection.prepare(" let mut statement = ok!(connection.prepare("
INSERT INTO data (integer, real) VALUES (?, ?) INSERT INTO data (a, b, c, d) VALUES (?, ?, ?, ?)
").unwrap(); "));
for i in 0..count { for i in 0..count {
statement.reset().unwrap(); ok!(statement.reset());
statement.bind(1, i as i64).unwrap(); ok!(statement.bind(1, i as i64));
statement.bind(2, i as f64).unwrap(); ok!(statement.bind(2, i as f64));
assert_eq!(statement.next().unwrap(), State::Done); ok!(statement.bind(3, i as f64));
ok!(statement.bind(4, i as f64));
assert_eq!(ok!(statement.next()), State::Done);
} }
} }