tursom/memgraph
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

created a script for compiling the simple client

Browse Source
This commit is contained in:
Dominik Tomičević 2016-03-15 20:24:01 +01:00
parent 5442f4b0b6
commit 8db98ae535
3 changed files with 27 additions and 32 deletions
api/resources
demo.hpp
demo/worker
client.cppcompile_client.sh

23
api/resources/demo.hpp
View File

@ -22,18 +22,16 @@ public:
stripper(make_query_stripper(TK_INT, TK_FLOAT, TK_STR, TK_BOOL))
{
query_f[7130961997552177283] = [db](const code_args_t& args) {
/* std::cout << "PRVI" << std::endl; */
auto& t = db->tx_engine.begin();
/* auto vertex_accessor = db->graph.vertices.insert(t); */
/* vertex_accessor.property( */
/* "id", args[0] */
/* ); */
auto vertex_accessor = db->graph.vertices.insert(t);
vertex_accessor.property(
"id", args[0]
);
t.commit();
return "EXECUTED: CREATE (n{id:X}) RETURN n";
};
query_f[11198568396549106428ull] = [db](const code_args_t& args) {
/* std::cout << "DRUGI" << std::endl; */
auto& t = db->tx_engine.begin();
auto id = args[0]->as<Int32>();
auto vertex_accessor = db->graph.vertices.find(t, id.value);
@ -42,7 +40,6 @@ public:
};
query_f[11637140396624918705ull] = [db](const code_args_t& args) {
/* std::cout << "TRECI" << std::endl; */
auto& t = db->tx_engine.begin();
auto id = args[0]->as<Int32>();
auto vertex_accessor = db->graph.vertices.find(t, id.value);
@ -58,7 +55,6 @@ public:
};
query_f[784140140862470291ull] = [db](const code_args_t& args) {
/* std::cout << "CETVRTI" << std::endl; */
auto& t = db->tx_engine.begin();
auto id1 = args[0]->as<Int32>();
auto v1 = db->graph.vertices.find(t, id1.value);
@ -90,7 +86,6 @@ public:
};
query_f[16940444920835972350ull] = [db](const code_args_t& args) {
/* std::cout << "PETI" << std::endl; */
auto& t = db->tx_engine.begin();
auto id = args[0]->as<Int32>();
auto v = db->graph.vertices.find(t, id.value);
@ -109,16 +104,14 @@ public:
auto strip = stripper.strip(query);
auto hash = fnv(strip.query);
/* std::cout << "'" << query << "'" << std::endl; */
auto it = query_f.find(hash);
if(it == query_f.end())
{
std::cout << "NOT FOUND" << std::endl;
std::cout << query << std::endl;
std::cout << hash << std::endl;
return std::string("NOT FOUND");
std::cout << "Unrecognized query '"
<< query << "' with hash "
<< hash << "." << std::endl;
return std::string("Unrecognized Query");
}
return it->second(strip.arguments);

35
demo/worker/client.cpp
View File

@ -8,7 +8,7 @@
void help()
{
std::cout << "error: too few arguments." << std::endl
<< "usage: host port connections duration[s]"
<< "usage: host port connections_per_query duration[s]"
<< std::endl;
std::exit(0);
@ -25,27 +25,28 @@ int main(int argc, char* argv[])
auto duration = std::stod(argv[4]);
// memgraph
std::vector<std::string> queries {
"CREATE (n{id:@}) RETURN n",
/* "MATCH (n{id:#}),(m{id:#}) CREATE (n)-[r:test]->(m) RETURN r", */
/* "MATCH (n{id:#}) SET n.prop = ^ RETURN n", */
/* "MATCH (n{id:#}) RETURN n", */
/* "MATCH (n{id:#})-[r]->(m) RETURN count(r)" */
};
//std::vector<std::string> queries {
// "CREATE (n{id:@}) RETURN n",
// "MATCH (n{id:#}),(m{id:#}) CREATE (n)-[r:test]->(m) RETURN r",
// "MATCH (n{id:#}) SET n.prop = ^ RETURN n",
// "MATCH (n{id:#}) RETURN n",
// "MATCH (n{id:#})-[r]->(m) RETURN count(r)"
//};
// neo4j
/* std::vector<std::string> queries { */
/* "CREATE (n:Item{id:@}) RETURN n", */
/* "MATCH (n:Item{id:#}),(m:Item{id:#}) CREATE (n)-[r:test]->(m) RETURN r", */
/* "MATCH (n:Item{id:#}) SET n.prop = ^ RETURN n", */
/* "MATCH (n:Item{id:#}) RETURN n", */
/* "MATCH (n:Item{id:#})-[r]->(m) RETURN count(r)" */
/* }; */
std::vector<std::string> queries {
"CREATE (n:Item{id:@}) RETURN n",
"MATCH (n:Item{id:#}),(m:Item{id:#}) CREATE (n)-[r:test]->(m) RETURN r",
"MATCH (n:Item{id:#}) SET n.prop = ^ RETURN n",
"MATCH (n:Item{id:#}) RETURN n",
"MATCH (n:Item{id:#})-[r]->(m) RETURN count(r)"
};
auto threads = queries.size();
std::cout << "Running queries on " << connections << " connections "
<< "using " << threads << " threads "
std::cout << "Running " << queries.size() << " queries each on "
<< connections << " connections "
<< "using a total of " << connections * threads << " connections "
<< "for " << duration << " seconds." << std::endl
<< "..." << std::endl;

1
demo/worker/compile_client.sh Executable file
View File

@ -0,0 +1 @@
clang++ -O2 -DNDEBUG -std=c++14 client.cpp -o client.out -I../../ -pthread