mirror of
https://gitee.com/acl-dev/acl.git
synced 2024-12-15 17:30:53 +08:00
214 lines
4.9 KiB
C++
214 lines
4.9 KiB
C++
#include "acl_cpp/lib_acl.hpp"
|
|
#include <getopt.h>
|
|
#include <unistd.h>
|
|
|
|
const char* CREATE_TBL =
|
|
"create table tbl_test\r\n"
|
|
"(key varchar(128) not null,\r\n"
|
|
" value varchar(128) not null,\r\n"
|
|
" primary key(key))\r\n";
|
|
|
|
class dbthread : public acl::thread {
|
|
public:
|
|
dbthread(const char* dbpath, const char* action, int max, acl::atomic_long& count)
|
|
: dbpath_(dbpath), action_(action), max_(max), count_(count) {}
|
|
~dbthread(void) {}
|
|
|
|
private:
|
|
acl::string dbpath_;
|
|
acl::string action_;
|
|
int max_;
|
|
acl::atomic_long& count_;
|
|
|
|
void* run(void) {
|
|
acl::db_sqlite db(dbpath_, "gbk");
|
|
|
|
if (db.open() == false) {
|
|
printf("open %s error\r\n", dbpath_.c_str());
|
|
return NULL;
|
|
}
|
|
|
|
if (tbl_create(db, "tbl_test") == false) {
|
|
return NULL;
|
|
}
|
|
|
|
int ret;
|
|
if (action_ == "add") {
|
|
ret = dbadd(db, max_);
|
|
} else if (action_ == "get") {
|
|
ret = dbget(db, max_);
|
|
} else if (action_ == "update") {
|
|
ret = dbupdate(db, max_);
|
|
} else if (action_ == "del") {
|
|
ret = dbdel(db, max_);
|
|
} else {
|
|
printf("unknown action: %s\r\n", action_.c_str());
|
|
return NULL;
|
|
}
|
|
printf("db-%s: %d\r\n", action_.c_str(), ret);
|
|
if (ret > 0) {
|
|
count_ += ret;
|
|
}
|
|
return NULL;
|
|
}
|
|
|
|
int dbadd(acl::db_handle& db, int max) {
|
|
acl::string sql;
|
|
assert(db.begin_transaction());
|
|
for (int i = 0; i < max; i++) {
|
|
sql.format("insert into tbl_test('key', 'value')"
|
|
" values('key-%d', 'value-%d')", i, i);
|
|
if (db.sql_update(sql) == false) {
|
|
printf("sql_update: |%s| error\r\n", sql.c_str());
|
|
return -1;
|
|
}
|
|
|
|
if (i > 0 && i % 1000 == 0) {
|
|
assert(db.commit());
|
|
assert(db.begin_transaction());
|
|
}
|
|
}
|
|
assert(db.commit());
|
|
return max;
|
|
}
|
|
|
|
int dbget(acl::db_handle& db, int max) {
|
|
acl::string sql, key, value;
|
|
int i;
|
|
for (i = 0; i < max; i++) {
|
|
key.format("key-%d", i);
|
|
sql.format("select value from tbl_test"
|
|
" where key='%s'", key.c_str());
|
|
if (db.sql_select(sql) == false) {
|
|
printf("sql_select: |%s| error\r\n", sql.c_str());
|
|
return -1;
|
|
}
|
|
if (db.length() == 0) {
|
|
break;
|
|
}
|
|
db.free_result();
|
|
}
|
|
return i;
|
|
}
|
|
|
|
int dbupdate(acl::db_handle& db, int max) {
|
|
acl::string sql, key, value;
|
|
for (int i = 0; i < max; i++) {
|
|
key.format("key-%d", i);
|
|
value.format("value-%d-%d", i, i);
|
|
sql.format("update tbl_test set value = '%s'"
|
|
" where key='%s'", value.c_str(), key.c_str());
|
|
if (db.sql_update(sql) == false) {
|
|
printf("sql_update: |%s| error\r\n", sql.c_str());
|
|
return -1;
|
|
}
|
|
}
|
|
|
|
return max;
|
|
}
|
|
|
|
int dbdel(acl::db_handle& db, int max) {
|
|
acl::string sql, key;
|
|
int n = 0;
|
|
for (int i = 0; i < max; i++) {
|
|
key.format("key-%d", i);
|
|
sql.format("delete from tbl_test where key='%s'",
|
|
key.c_str());
|
|
if (db.sql_update(sql) == false) {
|
|
printf("sql_update: |%s| error\r\n", sql.c_str());
|
|
return -1;
|
|
}
|
|
n += db.affect_count();
|
|
}
|
|
|
|
return n;
|
|
}
|
|
|
|
bool tbl_create(acl::db_handle& db, const char* tbl_name) {
|
|
if (db.tbl_exists(tbl_name)) {
|
|
return true;
|
|
}
|
|
if (db.sql_update(CREATE_TBL) == false) {
|
|
printf("create table failed\r\n");
|
|
return false;
|
|
}
|
|
return true;
|
|
}
|
|
};
|
|
|
|
static void usage(const char* procname) {
|
|
printf("usage: %s -h[help]\r\n"
|
|
" -s listen_addr[default: 127.0.0.1:7343\r\n"
|
|
" -n max[default: 1000]\r\n"
|
|
" -c nthreads[default: 1]\r\n"
|
|
" -p dbpath[default: .]\r\n"
|
|
" -l libpath[default: libsqlite3.so]\r\n"
|
|
" -a action[default: get, update|add|get|del\r\n"
|
|
, procname);
|
|
}
|
|
|
|
int main(int argc, char* argv[]) {
|
|
int nthreads = 1, max = 1000, ch;
|
|
acl::string dbpath = "./var", libpath = "./libsqlite3.so";
|
|
acl::string action = "get";
|
|
acl::string addr = "127.0.0.1:7343";
|
|
|
|
while ((ch = getopt(argc, argv, "hn:c:p:l:s:a:")) > 0) {
|
|
switch (ch) {
|
|
case 'h':
|
|
usage(argv[0]);
|
|
return 0;
|
|
case 'n':
|
|
max = atoi(optarg);
|
|
break;
|
|
case 'c':
|
|
nthreads = atoi(optarg);
|
|
break;
|
|
case 'p':
|
|
dbpath = optarg;
|
|
break;
|
|
case 'l':
|
|
libpath = optarg;
|
|
break;
|
|
case 's':
|
|
addr = optarg;
|
|
break;
|
|
case 'a':
|
|
action = optarg;
|
|
break;
|
|
default:
|
|
break;
|
|
}
|
|
}
|
|
|
|
if (access(libpath.c_str(), R_OK) == -1) {
|
|
printf("access %s failed %s\r\n", libpath.c_str(), acl::last_serror());
|
|
return 1;
|
|
}
|
|
|
|
acl::log::stdout_open(true);
|
|
acl::db_handle::set_loadpath(libpath);
|
|
|
|
acl::atomic_long success;
|
|
|
|
std::vector<acl::thread*> threads;
|
|
for (int i = 0; i < nthreads; i++) {
|
|
acl::string path;
|
|
path << dbpath << "/" << "db" << i << ".db";
|
|
acl::thread* thr = new dbthread(path, action, max, success);
|
|
threads.push_back(thr);
|
|
thr->start();
|
|
}
|
|
|
|
for (std::vector<acl::thread*>::iterator it = threads.begin();
|
|
it != threads.end(); ++it) {
|
|
|
|
(*it)->wait();
|
|
delete *it;
|
|
}
|
|
|
|
printf("All over, nthreads=%d, total=%d, success=%lld\r\n",
|
|
nthreads, nthreads * max, success.value());
|
|
return 0;
|
|
}
|