NextGraph
/
rkv
mirror of https://github.com/nextgraph-org/rkv.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Rename create_or_open to open_or_create

Browse Source
without.crypto
Nan Jiang 6 years ago
parent 56d9e85c9e
commit f5efc66559
5 changed files with 22 additions and 22 deletions
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Show Stats Download Patch File Download Diff File
  1. 2
      examples/iterator.rs
  2. 2
      examples/simple-store.rs
  3. 34
      src/env.rs
  4. 2
      src/integer.rs
  5. 4
      src/lib.rs

2
examples/iterator.rs
Unescape View File

@ -29,7 +29,7 @@ fn main() {
let created_arc = Manager::singleton().write().unwrap().get_or_create(p, Rkv::new).unwrap();
let k = created_arc.read().unwrap();
let store: Store<&str> = k.create_or_open("store").unwrap();
let store: Store<&str> = k.open_or_create("store").unwrap();
populate_store(&k, &store).unwrap();

2
examples/simple-store.rs
Unescape View File

@ -30,7 +30,7 @@ fn main() {
let k = created_arc.read().unwrap();
// Creates a store called "store"
let store: Store<&str> = k.create_or_open("store").unwrap();
let store: Store<&str> = k.open_or_create("store").unwrap();
println!("Inserting data...");
{

34
src/env.rs
Unescape View File

@ -85,20 +85,20 @@ impl Rkv {
/// Store creation methods.
impl Rkv {
pub fn create_or_open_default(&self) -> Result<Store<&str>, StoreError> {
self.create_or_open(None)
pub fn open_or_create_default(&self) -> Result<Store<&str>, StoreError> {
self.open_or_create(None)
}
pub fn create_or_open<'s, T, K>(&self, name: T) -> Result<Store<K>, StoreError>
pub fn open_or_create<'s, T, K>(&self, name: T) -> Result<Store<K>, StoreError>
where
T: Into<Option<&'s str>>,
K: AsRef<[u8]>,
{
let flags = DatabaseFlags::empty();
self.create_or_open_with_flags(name, flags)
self.open_or_create_with_flags(name, flags)
}
pub fn create_or_open_integer<'s, T, K>(&self, name: T) -> Result<IntegerStore<K>, StoreError>
pub fn open_or_create_integer<'s, T, K>(&self, name: T) -> Result<IntegerStore<K>, StoreError>
where
T: Into<Option<&'s str>>,
K: PrimitiveInt,
@ -112,7 +112,7 @@ impl Rkv {
Ok(IntegerStore::new(db))
}
pub fn create_or_open_with_flags<'s, T, K>(&self, name: T, flags: DatabaseFlags) -> Result<Store<K>, StoreError>
pub fn open_or_create_with_flags<'s, T, K>(&self, name: T, flags: DatabaseFlags) -> Result<Store<K>, StoreError>
where
T: Into<Option<&'s str>>,
K: AsRef<[u8]>,
@ -182,9 +182,9 @@ mod tests {
assert!(root.path().is_dir());
let k = Rkv::new(root.path()).expect("new succeeded");
let _ = k.create_or_open_default().expect("created default");
let _ = k.open_or_create_default().expect("created default");
let yyy: Store<&str> = k.create_or_open("yyy").expect("opened");
let yyy: Store<&str> = k.open_or_create("yyy").expect("opened");
let reader = yyy.read(&k).expect("reader");
let result = reader.get("foo");
@ -197,7 +197,7 @@ mod tests {
fs::create_dir_all(root.path()).expect("dir created");
let k = Rkv::new(root.path()).expect("new succeeded");
let sk: Store<&str> = k.create_or_open("sk").expect("opened");
let sk: Store<&str> = k.open_or_create("sk").expect("opened");
{
let mut writer = sk.write(&k).expect("writer");
@ -297,7 +297,7 @@ mod tests {
let root = Builder::new().prefix("test_read_before_write_num").tempdir().expect("tempdir");
fs::create_dir_all(root.path()).expect("dir created");
let k = Rkv::new(root.path()).expect("new succeeded");
let sk: Store<&str> = k.create_or_open("sk").expect("opened");
let sk: Store<&str> = k.open_or_create("sk").expect("opened");
// Test reading a number, modifying it, and then writing it back.
// We have to be done with the Value::I64 before calling Writer::put,
@ -326,7 +326,7 @@ mod tests {
let root = Builder::new().prefix("test_read_before_write_str").tempdir().expect("tempdir");
fs::create_dir_all(root.path()).expect("dir created");
let k = Rkv::new(root.path()).expect("new succeeded");
let sk: Store<&str> = k.create_or_open("sk").expect("opened");
let sk: Store<&str> = k.open_or_create("sk").expect("opened");
// Test reading a string, modifying it, and then writing it back.
// We have to be done with the Value::Str before calling Writer::put,
@ -348,7 +348,7 @@ mod tests {
let root = Builder::new().prefix("test_concurrent_reads_prohibited").tempdir().expect("tempdir");
fs::create_dir_all(root.path()).expect("dir created");
let k = Rkv::new(root.path()).expect("new succeeded");
let s: Store<&str> = k.create_or_open("s").expect("opened");
let s: Store<&str> = k.open_or_create("s").expect("opened");
let _first = s.read(&k).expect("reader");
let second = s.read(&k);
@ -368,7 +368,7 @@ mod tests {
let root = Builder::new().prefix("test_isolation").tempdir().expect("tempdir");
fs::create_dir_all(root.path()).expect("dir created");
let k = Rkv::new(root.path()).expect("new succeeded");
let s: Store<&str> = k.create_or_open("s").expect("opened");
let s: Store<&str> = k.open_or_create("s").expect("opened");
// Add one field.
{
@ -415,7 +415,7 @@ mod tests {
let root = Builder::new().prefix("test_round_trip_blob").tempdir().expect("tempdir");
fs::create_dir_all(root.path()).expect("dir created");
let k = Rkv::new(root.path()).expect("new succeeded");
let sk: Store<&str> = k.create_or_open("sk").expect("opened");
let sk: Store<&str> = k.open_or_create("sk").expect("opened");
let mut writer = sk.write(&k).expect("writer");
assert_eq!(writer.get("foo").expect("read"), None);
@ -453,7 +453,7 @@ mod tests {
let root = Builder::new().prefix("test_delete_value").tempdir().expect("tempdir");
fs::create_dir_all(root.path()).expect("dir created");
let k = Rkv::new(root.path()).expect("new succeeded");
let sk: Store<&str> = k.create_or_open_with_flags("sk", lmdb::DUP_SORT).expect("opened");
let sk: Store<&str> = k.open_or_create_with_flags("sk", lmdb::DUP_SORT).expect("opened");
let mut writer = sk.write(&k).expect("writer");
writer.put("foo", &Value::I64(1234)).expect("wrote");
@ -466,7 +466,7 @@ mod tests {
let root = Builder::new().prefix("test_iter").tempdir().expect("tempdir");
fs::create_dir_all(root.path()).expect("dir created");
let k = Rkv::new(root.path()).expect("new succeeded");
let sk: Store<&str> = k.create_or_open("sk").expect("opened");
let sk: Store<&str> = k.open_or_create("sk").expect("opened");
// An iterator over an empty store returns no values.
{
@ -541,7 +541,7 @@ mod tests {
let root = Builder::new().prefix("test_iter_from_key_greater_than_existing").tempdir().expect("tempdir");
fs::create_dir_all(root.path()).expect("dir created");
let k = Rkv::new(root.path()).expect("new succeeded");
let sk: Store<&str> = k.create_or_open("sk").expect("opened");
let sk: Store<&str> = k.open_or_create("sk").expect("opened");
let mut writer = sk.write(&k).expect("writer");
writer.put("foo", &Value::I64(1234)).expect("wrote");

2
src/integer.rs
Unescape View File

@ -174,7 +174,7 @@ mod tests {
let root = Builder::new().prefix("test_integer_keys").tempdir().expect("tempdir");
fs::create_dir_all(root.path()).expect("dir created");
let k = Rkv::new(root.path()).expect("new succeeded");
let mut s: IntegerStore<u32> = k.create_or_open_integer("s").expect("open");
let mut s: IntegerStore<u32> = k.open_or_create_integer("s").expect("open");
let mut writer = s.write(&k).expect("writer");

4
src/lib.rs
Unescape View File

@ -65,9 +65,9 @@
//! let created_arc = Manager::singleton().write().unwrap().get_or_create(path, Rkv::new).unwrap();
//! let env = created_arc.read().unwrap();
//!
//! // Call `Rkv.create_or_open_default()` to get a handle to the default
//! // Call `Rkv.open_or_create_default()` to get a handle to the default
//! // (unnamed) store for the environment.
//! let store: Store<&str> = env.create_or_open_default().unwrap();
//! let store: Store<&str> = env.open_or_create_default().unwrap();
//!
//! {
//! // Use a write transaction to mutate the store by calling

Write Preview
Loading…
Cancel
Save