moneroexamples
8 years ago
parent
fbba97dfed
commit
3ec44a658c
@ -0,0 +1,755 @@
|
||||
//
|
||||
// Created by mwo on 27/04/16.
|
||||
//
|
||||
#ifndef XMRLMDBCPP_MYLMDB_H
|
||||
#define XMRLMDBCPP_MYLMDB_H
|
||||
|
||||
#include "../ext/lmdb++.h"
|
||||
|
||||
#include <iostream>
|
||||
#include <memory>
|
||||
|
||||
namespace xmreg
|
||||
{
|
||||
|
||||
using epee::string_tools::pod_to_hex;
|
||||
using epee::string_tools::hex_to_pod;
|
||||
|
||||
using namespace std;
|
||||
|
||||
|
||||
|
||||
/**
|
||||
* Stores info about outputs useful
|
||||
* for checking which ouputs belong to a
|
||||
* given address and viewkey
|
||||
*/
|
||||
struct output_info
|
||||
{
|
||||
crypto::public_key out_pub_key;
|
||||
crypto::hash tx_hash;
|
||||
crypto::public_key tx_pub_key;
|
||||
uint64_t amount;
|
||||
uint64_t index_in_tx;
|
||||
};
|
||||
|
||||
std::ostream& operator<<(std::ostream& os, const output_info& out_info)
|
||||
{
|
||||
os << ", out_pub_key: " << out_info.out_pub_key
|
||||
<< ", tx_hash: " << out_info.tx_hash
|
||||
<< ", tx_pub_key: " << out_info.tx_pub_key
|
||||
<< ", amount: " << XMR_AMOUNT(out_info.amount)
|
||||
<< ", index_in_tx: " << out_info.index_in_tx;
|
||||
|
||||
return os;
|
||||
}
|
||||
|
||||
class MyLMDB
|
||||
{
|
||||
|
||||
|
||||
static const uint64_t DEFAULT_MAPSIZE = 30UL * 1024UL * 1024UL * 1024UL; /* 30 GiB */
|
||||
static const uint64_t DEFAULT_NO_DBs = 10;
|
||||
|
||||
|
||||
string m_db_path;
|
||||
|
||||
uint64_t m_mapsize;
|
||||
uint64_t m_no_dbs;
|
||||
|
||||
lmdb::env m_env;
|
||||
|
||||
|
||||
public:
|
||||
MyLMDB(string _path,
|
||||
uint64_t _mapsize = DEFAULT_MAPSIZE,
|
||||
uint64_t _no_dbs = DEFAULT_NO_DBs)
|
||||
: m_db_path {_path},
|
||||
m_mapsize {_mapsize},
|
||||
m_no_dbs {_no_dbs},
|
||||
m_env {nullptr}
|
||||
{
|
||||
create_and_open_env();
|
||||
}
|
||||
|
||||
bool
|
||||
create_and_open_env()
|
||||
{
|
||||
try
|
||||
{ m_env = lmdb::env::create();
|
||||
m_env.set_mapsize(m_mapsize);
|
||||
m_env.set_max_dbs(m_no_dbs);
|
||||
m_env.open(m_db_path.c_str(), MDB_CREATE, 0664);
|
||||
}
|
||||
catch (lmdb::error& e )
|
||||
{
|
||||
cerr << e.what() << endl;
|
||||
return false;
|
||||
}
|
||||
|
||||
return true;
|
||||
}
|
||||
|
||||
|
||||
bool
|
||||
write_key_images(const transaction& tx)
|
||||
{
|
||||
crypto::hash tx_hash = get_transaction_hash(tx);
|
||||
|
||||
string tx_hash_str = pod_to_hex(tx_hash);
|
||||
|
||||
vector<cryptonote::txin_to_key> key_images
|
||||
= xmreg::get_key_images(tx);
|
||||
|
||||
lmdb::txn wtxn {nullptr};
|
||||
lmdb::dbi wdbi {0};
|
||||
|
||||
unsigned int flags = MDB_CREATE | MDB_DUPSORT | MDB_DUPFIXED;
|
||||
|
||||
try
|
||||
{
|
||||
wtxn = lmdb::txn::begin(m_env);
|
||||
wdbi = lmdb::dbi::open(wtxn, "key_images", flags);
|
||||
}
|
||||
catch (lmdb::error& e )
|
||||
{
|
||||
cerr << e.what() << endl;
|
||||
return false;
|
||||
}
|
||||
|
||||
for (const cryptonote::txin_to_key& key_image: key_images)
|
||||
{
|
||||
string key_img_str = pod_to_hex(key_image.k_image);
|
||||
|
||||
lmdb::val key_img_val {key_img_str};
|
||||
lmdb::val tx_hash_val {tx_hash_str};
|
||||
|
||||
wdbi.put(wtxn, key_img_val, tx_hash_val);
|
||||
}
|
||||
|
||||
try
|
||||
{
|
||||
wtxn.commit();
|
||||
}
|
||||
catch (lmdb::error& e )
|
||||
{
|
||||
cerr << e.what() << endl;
|
||||
return false;
|
||||
}
|
||||
|
||||
return true;
|
||||
}
|
||||
|
||||
bool
|
||||
write_output_public_keys(const transaction& tx, const block& blk)
|
||||
{
|
||||
crypto::hash tx_hash = get_transaction_hash(tx);
|
||||
|
||||
crypto::public_key tx_pub_key = get_tx_pub_key_from_extra(tx);
|
||||
|
||||
string tx_hash_str = pod_to_hex(tx_hash);
|
||||
|
||||
vector<tuple<txout_to_key, uint64_t, uint64_t>> outputs =
|
||||
xmreg::get_ouputs_tuple(tx);
|
||||
|
||||
lmdb::txn wtxn {nullptr};
|
||||
lmdb::dbi wdbi1 {0};
|
||||
lmdb::dbi wdbi2 {0};
|
||||
lmdb::dbi wdbi3 {0};
|
||||
|
||||
unsigned int flags = MDB_CREATE | MDB_DUPSORT | MDB_DUPFIXED;
|
||||
|
||||
try
|
||||
{
|
||||
wtxn = lmdb::txn::begin(m_env);
|
||||
wdbi1 = lmdb::dbi::open(wtxn, "output_public_keys", flags);
|
||||
wdbi2 = lmdb::dbi::open(wtxn, "output_amounts", flags);
|
||||
wdbi3 = lmdb::dbi::open(wtxn, "output_info",
|
||||
flags | MDB_INTEGERKEY | MDB_INTEGERDUP);
|
||||
}
|
||||
catch (lmdb::error& e )
|
||||
{
|
||||
cerr << e.what() << endl;
|
||||
return false;
|
||||
}
|
||||
|
||||
for (auto& output: outputs)
|
||||
{
|
||||
|
||||
public_key out_pub_key = std::get<0>(output).key;
|
||||
|
||||
string public_key_str = pod_to_hex(out_pub_key);
|
||||
|
||||
lmdb::val public_key_val {public_key_str};
|
||||
lmdb::val tx_hash_val {tx_hash_str};
|
||||
|
||||
uint64_t amount = std::get<1>(output);
|
||||
|
||||
lmdb::val amount_val {static_cast<void*>(&amount), sizeof(amount)};
|
||||
|
||||
uint64_t index_in_tx = std::get<2>(output);
|
||||
|
||||
output_info out_info {out_pub_key, tx_hash,
|
||||
tx_pub_key, amount,
|
||||
index_in_tx};
|
||||
|
||||
uint64_t out_timestamp = blk.timestamp;
|
||||
|
||||
lmdb::val out_timestamp_val {static_cast<void*>(&out_timestamp),
|
||||
sizeof(out_timestamp)};
|
||||
lmdb::val out_info_val {static_cast<void*>(&out_info),
|
||||
sizeof(out_info)};
|
||||
|
||||
wdbi1.put(wtxn, public_key_val, tx_hash_val);
|
||||
wdbi2.put(wtxn, public_key_val, amount_val);
|
||||
wdbi3.put(wtxn, out_timestamp_val, out_info_val);
|
||||
}
|
||||
|
||||
try
|
||||
{
|
||||
wtxn.commit();
|
||||
}
|
||||
catch (lmdb::error& e )
|
||||
{
|
||||
cerr << e.what() << endl;
|
||||
return false;
|
||||
}
|
||||
|
||||
return true;
|
||||
}
|
||||
|
||||
bool
|
||||
write_tx_public_key(const transaction& tx)
|
||||
{
|
||||
crypto::hash tx_hash = get_transaction_hash(tx);
|
||||
|
||||
string tx_hash_str = pod_to_hex(tx_hash);
|
||||
|
||||
unsigned int flags = MDB_CREATE | MDB_DUPSORT | MDB_DUPFIXED;
|
||||
|
||||
public_key pk = get_tx_pub_key_from_extra(tx);
|
||||
|
||||
string pk_str = pod_to_hex(pk);
|
||||
|
||||
try
|
||||
{
|
||||
lmdb::txn wtxn = lmdb::txn::begin(m_env);
|
||||
lmdb::dbi wdbi = lmdb::dbi::open(wtxn, "tx_public_keys", flags);
|
||||
|
||||
//cout << "Saving public_key: " << pk_str << endl;
|
||||
|
||||
lmdb::val public_key_val {pk_str};
|
||||
lmdb::val tx_hash_val {tx_hash_str};
|
||||
|
||||
wdbi.put(wtxn, public_key_val, tx_hash_val);
|
||||
|
||||
wtxn.commit();
|
||||
}
|
||||
catch (lmdb::error& e)
|
||||
{
|
||||
cerr << e.what() << endl;
|
||||
return false;
|
||||
}
|
||||
|
||||
return true;
|
||||
}
|
||||
|
||||
bool
|
||||
write_payment_id(const transaction& tx)
|
||||
{
|
||||
crypto::hash tx_hash = get_transaction_hash(tx);
|
||||
|
||||
string tx_hash_str = pod_to_hex(tx_hash);
|
||||
|
||||
crypto::hash payment_id;
|
||||
crypto::hash8 payment_id8;
|
||||
|
||||
get_payment_id(tx, payment_id, payment_id8);
|
||||
|
||||
if (payment_id == null_hash)
|
||||
{
|
||||
return true;
|
||||
}
|
||||
|
||||
unsigned int flags = MDB_CREATE | MDB_DUPSORT | MDB_DUPFIXED;
|
||||
|
||||
string payment_id_str = pod_to_hex(payment_id);
|
||||
|
||||
try
|
||||
{
|
||||
lmdb::txn wtxn = lmdb::txn::begin(m_env);
|
||||
lmdb::dbi wdbi = lmdb::dbi::open(wtxn, "payments_id", flags);
|
||||
|
||||
//cout << "Saving payiment_id: " << payment_id_str << endl;
|
||||
|
||||
lmdb::val payment_id_val {payment_id_str};
|
||||
lmdb::val tx_hash_val {tx_hash_str};
|
||||
|
||||
wdbi.put(wtxn, payment_id_val, tx_hash_val);
|
||||
|
||||
wtxn.commit();
|
||||
}
|
||||
catch (lmdb::error& e)
|
||||
{
|
||||
cerr << e.what() << endl;
|
||||
return false;
|
||||
}
|
||||
|
||||
return true;
|
||||
}
|
||||
|
||||
bool
|
||||
write_encrypted_payment_id(const transaction& tx)
|
||||
{
|
||||
crypto::hash tx_hash = get_transaction_hash(tx);
|
||||
|
||||
string tx_hash_str = pod_to_hex(tx_hash);
|
||||
|
||||
crypto::hash payment_id;
|
||||
crypto::hash8 payment_id8;
|
||||
|
||||
get_payment_id(tx, payment_id, payment_id8);
|
||||
|
||||
if (payment_id8 == null_hash8)
|
||||
{
|
||||
return true;
|
||||
}
|
||||
|
||||
unsigned int flags = MDB_CREATE | MDB_DUPSORT | MDB_DUPFIXED;
|
||||
|
||||
string payment_id_str = pod_to_hex(payment_id8);
|
||||
|
||||
try
|
||||
{
|
||||
lmdb::txn wtxn = lmdb::txn::begin(m_env);
|
||||
lmdb::dbi wdbi = lmdb::dbi::open(wtxn, "encrypted_payments_id", flags);
|
||||
|
||||
//cout << "Saving encrypted payiment_id: " << payment_id_str << endl;
|
||||
//string wait_for_enter;
|
||||
//cin >> wait_for_enter;
|
||||
|
||||
lmdb::val payment_id_val {payment_id_str};
|
||||
lmdb::val tx_hash_val {tx_hash_str};
|
||||
|
||||
wdbi.put(wtxn, payment_id_val, tx_hash_val);
|
||||
|
||||
wtxn.commit();
|
||||
}
|
||||
catch (lmdb::error& e)
|
||||
{
|
||||
cerr << e.what() << endl;
|
||||
return false;
|
||||
}
|
||||
|
||||
return true;
|
||||
}
|
||||
|
||||
// // this seems to be not needed as outputs are written based on timestamps
|
||||
//
|
||||
// bool
|
||||
// write_block_timestamp(uint64_t& blk_timestamp, uint64_t& blk_height)
|
||||
// {
|
||||
//
|
||||
// unsigned int flags = MDB_CREATE | MDB_INTEGERKEY;
|
||||
//
|
||||
// try
|
||||
// {
|
||||
// lmdb::txn wtxn = lmdb::txn::begin(m_env);
|
||||
// lmdb::dbi wdbi = lmdb::dbi::open(wtxn, "block_timestamps", flags);
|
||||
//
|
||||
// lmdb::val blk_timestamp_val {static_cast<void*>(&blk_timestamp),
|
||||
// sizeof(blk_timestamp)};
|
||||
// lmdb::val blk_height_val {static_cast<void*>(&blk_height),
|
||||
// sizeof(blk_height)};
|
||||
//
|
||||
// wdbi.put(wtxn, blk_timestamp_val, blk_height_val);
|
||||
//
|
||||
// wtxn.commit();
|
||||
// }
|
||||
// catch (lmdb::error& e)
|
||||
// {
|
||||
// cerr << e.what() << endl;
|
||||
// return false;
|
||||
// }
|
||||
//
|
||||
// return true;
|
||||
// }
|
||||
|
||||
bool
|
||||
search(const string& key,
|
||||
vector<string>& found_tx_hashes,
|
||||
const string& db_name = "key_images")
|
||||
{
|
||||
unsigned int flags = MDB_DUPSORT | MDB_DUPFIXED;
|
||||
|
||||
try
|
||||
{
|
||||
|
||||
lmdb::txn rtxn = lmdb::txn::begin(m_env, nullptr, MDB_RDONLY);
|
||||
lmdb::dbi rdbi = lmdb::dbi::open(rtxn, db_name.c_str(), flags);
|
||||
lmdb::cursor cr = lmdb::cursor::open(rtxn, rdbi);
|
||||
|
||||
lmdb::val key_to_find{key};
|
||||
lmdb::val tx_hash_val;
|
||||
|
||||
// set cursor the the first item
|
||||
if (cr.get(key_to_find, tx_hash_val, MDB_SET))
|
||||
{
|
||||
//cout << key_val_to_str(key_to_find, tx_hash_val) << endl;
|
||||
found_tx_hashes.push_back(string(tx_hash_val.data(), tx_hash_val.size()));
|
||||
|
||||
// process other values for the same key
|
||||
while (cr.get(key_to_find, tx_hash_val, MDB_NEXT_DUP))
|
||||
{
|
||||
//cout << key_val_to_str(key_to_find, tx_hash_val) << endl;
|
||||
found_tx_hashes.push_back(string(tx_hash_val.data(), tx_hash_val.size()));
|
||||
}
|
||||
}
|
||||
else
|
||||
{
|
||||
return false;
|
||||
}
|
||||
|
||||
cr.close();
|
||||
rtxn.abort();
|
||||
|
||||
}
|
||||
catch (lmdb::error& e)
|
||||
{
|
||||
cerr << e.what() << endl;
|
||||
return false;
|
||||
}
|
||||
|
||||
return true;
|
||||
}
|
||||
|
||||
bool
|
||||
get_output_amount(const string& key,
|
||||
uint64_t& amount,
|
||||
const string& db_name = "output_amounts")
|
||||
{
|
||||
|
||||
unsigned int flags = 0;
|
||||
|
||||
try
|
||||
{
|
||||
|
||||
lmdb::txn rtxn = lmdb::txn::begin(m_env, nullptr, MDB_RDONLY);
|
||||
lmdb::dbi rdbi = lmdb::dbi::open(rtxn, db_name.c_str(), flags);
|
||||
|
||||
lmdb::val key_to_find{key};
|
||||
lmdb::val amount_val;
|
||||
|
||||
if(!rdbi.get(rtxn, key_to_find, amount_val))
|
||||
{
|
||||
return false;
|
||||
}
|
||||
|
||||
amount = *(amount_val.data<uint64_t>());
|
||||
|
||||
rtxn.abort();
|
||||
|
||||
}
|
||||
catch (lmdb::error& e)
|
||||
{
|
||||
cerr << e.what() << endl;
|
||||
return false;
|
||||
}
|
||||
|
||||
return true;
|
||||
}
|
||||
|
||||
|
||||
bool
|
||||
get_output_info(uint64_t key_timestamp,
|
||||
vector<output_info>& out_infos,
|
||||
const string& db_name = "output_info")
|
||||
{
|
||||
|
||||
unsigned int flags = 0;
|
||||
|
||||
try
|
||||
{
|
||||
|
||||
lmdb::txn rtxn = lmdb::txn::begin(m_env, nullptr, MDB_RDONLY);
|
||||
lmdb::dbi rdbi = lmdb::dbi::open(rtxn, db_name.c_str(), flags);
|
||||
|
||||
lmdb::val key_to_find{static_cast<void*>(&key_timestamp),
|
||||
sizeof(key_timestamp)};
|
||||
lmdb::val info_val;
|
||||
|
||||
lmdb::cursor cr = lmdb::cursor::open(rtxn, rdbi);
|
||||
|
||||
// set cursor the the first item
|
||||
if (cr.get(key_to_find, info_val, MDB_SET_RANGE))
|
||||
{
|
||||
out_infos.push_back(*(info_val.data<output_info>()));
|
||||
|
||||
// process other values for the same key
|
||||
while (cr.get(key_to_find, info_val, MDB_NEXT_DUP))
|
||||
{
|
||||
//cout << key_val_to_str(key_to_find, tx_hash_val) << endl;
|
||||
out_infos.push_back(*(info_val.data<output_info>()));
|
||||
}
|
||||
}
|
||||
else
|
||||
{
|
||||
return false;
|
||||
}
|
||||
|
||||
rtxn.abort();
|
||||
|
||||
}
|
||||
catch (lmdb::error& e)
|
||||
{
|
||||
cerr << e.what() << endl;
|
||||
return false;
|
||||
}
|
||||
|
||||
return true;
|
||||
}
|
||||
|
||||
bool
|
||||
get_output_info_range(uint64_t key_timestamp_start,
|
||||
uint64_t key_timestamp_end,
|
||||
vector<pair<uint64_t, output_info>>& out_infos,
|
||||
const string& db_name = "output_info")
|
||||
{
|
||||
|
||||
unsigned int flags = 0;
|
||||
|
||||
try
|
||||
{
|
||||
lmdb::txn rtxn = lmdb::txn::begin(m_env, nullptr, MDB_RDONLY);
|
||||
lmdb::dbi rdbi = lmdb::dbi::open(rtxn, db_name.c_str(), flags);
|
||||
|
||||
lmdb::val key_to_find{static_cast<void*>(&key_timestamp_start),
|
||||
sizeof(key_timestamp_start)};
|
||||
lmdb::val info_val;
|
||||
|
||||
lmdb::cursor cr = lmdb::cursor::open(rtxn, rdbi);
|
||||
|
||||
uint64_t current_timestamp = key_timestamp_start;
|
||||
|
||||
// set cursor the the first item
|
||||
if (cr.get(key_to_find, info_val, MDB_SET_RANGE))
|
||||
{
|
||||
|
||||
current_timestamp = *key_to_find.data<uint64_t>();
|
||||
|
||||
if (current_timestamp > key_timestamp_end)
|
||||
{
|
||||
return false;
|
||||
}
|
||||
|
||||
out_infos.push_back(make_pair(
|
||||
current_timestamp,
|
||||
*(info_val.data<output_info>())));
|
||||
|
||||
// process other values for the same key
|
||||
while (cr.get(key_to_find, info_val, MDB_NEXT))
|
||||
{
|
||||
current_timestamp = *key_to_find.data<uint64_t>();
|
||||
|
||||
if (current_timestamp > key_timestamp_end)
|
||||
{
|
||||
break;
|
||||
}
|
||||
|
||||
out_infos.push_back(make_pair(
|
||||
current_timestamp,
|
||||
*(info_val.data<output_info>())));
|
||||
}
|
||||
}
|
||||
else
|
||||
{
|
||||
return false;
|
||||
}
|
||||
|
||||
rtxn.abort();
|
||||
|
||||
}
|
||||
catch (lmdb::error& e)
|
||||
{
|
||||
cerr << e.what() << endl;
|
||||
return false;
|
||||
}
|
||||
|
||||
return true;
|
||||
}
|
||||
|
||||
/**
|
||||
* Returns sorted and unique tx hashes withing a
|
||||
* given timestamp range
|
||||
*
|
||||
* @param key_timestamp_start
|
||||
* @param key_timestamp_end
|
||||
* @param out_txs
|
||||
* @return bool
|
||||
*/
|
||||
bool
|
||||
get_txs_from_timestamp_range(uint64_t key_timestamp_start,
|
||||
uint64_t key_timestamp_end,
|
||||
vector<crypto::hash>& out_txs)
|
||||
{
|
||||
using output_pair = pair<uint64_t, output_info>;
|
||||
|
||||
auto sort_by_timestamp = [](const output_pair& l,
|
||||
const output_pair& r)
|
||||
{
|
||||
return l.first < r.first;
|
||||
};
|
||||
|
||||
vector<output_pair> out_infos;
|
||||
|
||||
if (get_output_info_range(key_timestamp_start,
|
||||
key_timestamp_end,
|
||||
out_infos))
|
||||
{
|
||||
|
||||
set<output_pair, decltype(sort_by_timestamp)> unique_txs(sort_by_timestamp);
|
||||
|
||||
for (auto oi: out_infos)
|
||||
unique_txs.insert(oi);
|
||||
|
||||
for (auto ut: unique_txs)
|
||||
out_txs.push_back(ut.second.tx_hash);
|
||||
|
||||
return true;
|
||||
}
|
||||
|
||||
return false;
|
||||
}
|
||||
|
||||
|
||||
|
||||
void
|
||||
for_all_outputs(
|
||||
std::function<bool(public_key& out_pubkey,
|
||||
output_info& out_info)> f)
|
||||
{
|
||||
unsigned int flags = MDB_DUPSORT | MDB_DUPFIXED;
|
||||
|
||||
try
|
||||
{
|
||||
|
||||
lmdb::txn rtxn = lmdb::txn::begin(m_env, nullptr, MDB_RDONLY);
|
||||
lmdb::dbi rdbi = lmdb::dbi::open(rtxn, "output_info", flags);
|
||||
lmdb::cursor cr = lmdb::cursor::open(rtxn, rdbi);
|
||||
|
||||
lmdb::val key_to_find;
|
||||
lmdb::val amount_val;
|
||||
|
||||
|
||||
// process all values for the same key
|
||||
while (cr.get(key_to_find, amount_val, MDB_NEXT))
|
||||
{
|
||||
public_key pub_key;
|
||||
|
||||
hex_to_pod(string(key_to_find.data(), key_to_find.size()),
|
||||
pub_key);
|
||||
|
||||
output_info out_info = *(amount_val.data<output_info>());
|
||||
|
||||
if (f(pub_key, out_info) == false)
|
||||
{
|
||||
break;
|
||||
}
|
||||
}
|
||||
|
||||
cr.close();
|
||||
rtxn.abort();
|
||||
|
||||
}
|
||||
catch (lmdb::error& e)
|
||||
{
|
||||
cerr << e.what() << endl;
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
void
|
||||
print_all(const string& db_name)
|
||||
{
|
||||
unsigned int flags = MDB_DUPSORT | MDB_DUPFIXED;
|
||||
|
||||
try
|
||||
{
|
||||
|
||||
lmdb::txn rtxn = lmdb::txn::begin(m_env, nullptr, MDB_RDONLY);
|
||||
lmdb::dbi rdbi = lmdb::dbi::open(rtxn, db_name.c_str(), flags);
|
||||
lmdb::cursor cr = lmdb::cursor::open(rtxn, rdbi);
|
||||
|
||||
lmdb::val key_to_find;
|
||||
lmdb::val tx_hash_val;
|
||||
|
||||
|
||||
// process other values for the same key
|
||||
while (cr.get(key_to_find, tx_hash_val, MDB_NEXT))
|
||||
{
|
||||
cout << key_val_to_str(key_to_find, tx_hash_val) << endl;
|
||||
}
|
||||
|
||||
cr.close();
|
||||
rtxn.abort();
|
||||
|
||||
}
|
||||
catch (lmdb::error& e)
|
||||
{
|
||||
cerr << e.what() << endl;
|
||||
}
|
||||
}
|
||||
|
||||
static uint64_t
|
||||
get_blockchain_height(string blk_path = "/home/mwo/.blockchain/lmdb")
|
||||
{
|
||||
uint64_t height {0};
|
||||
|
||||
try
|
||||
{
|
||||
auto env = lmdb::env::create();
|
||||
env.set_mapsize(DEFAULT_MAPSIZE * 3);
|
||||
env.set_max_dbs(20);
|
||||
env.open(blk_path.c_str(), MDB_CREATE, 0664);
|
||||
|
||||
//auto rtxn = lmdb::txn::begin(env, nullptr, MDB_RDONLY);
|
||||
auto rtxn = lmdb::txn::begin(env, nullptr);
|
||||
auto rdbi = lmdb::dbi::open(rtxn, "blocks");
|
||||
|
||||
MDB_stat stats = rdbi.stat(rtxn);
|
||||
|
||||
height = static_cast<uint64_t>(stats.ms_entries);
|
||||
|
||||
rtxn.abort();
|
||||
}
|
||||
catch (lmdb::error& e)
|
||||
{
|
||||
cerr << e.what() << endl;
|
||||
return height;
|
||||
}
|
||||
catch (exception& e)
|
||||
{
|
||||
cerr << e.what() << endl;
|
||||
return height;
|
||||
}
|
||||
|
||||
//cout << height << endl;
|
||||
|
||||
return height;
|
||||
|
||||
}
|
||||
|
||||
string
|
||||
key_val_to_str(const lmdb::val& key, const lmdb::val& val)
|
||||
{
|
||||
return "key: " + string(key.data(), key.size())
|
||||
+ ", val: " + string(val.data(), val.size());
|
||||
}
|
||||
|
||||
|
||||
|
||||
};
|
||||
|
||||
}
|
||||
|
||||
#endif //XMRLMDBCPP_MYLMDB_H
|
||||
Loading…
Reference in new issue