feat(orm): update examples to new Database API and add HTTP ORM showcase

Author: GaspardKirira

examples/.env.example

@@ -0,0 +1,37 @@
+# =========================================================
+# Vix HTTP + DB showcase
+# Copy this file to ".env"
+# =========================================================
+
+# Database engine:
+#   - sqlite
+#   - mysql
+DATABASE_ENGINE=sqlite
+
+# SQLite configuration
+DATABASE_SQLITE_PATH=vix.db
+
+# MySQL configuration
+# Used only if DATABASE_ENGINE=mysql
+DATABASE_DEFAULT_HOST=127.0.0.1
+DATABASE_DEFAULT_PORT=3306
+DATABASE_DEFAULT_USER=root
+DATABASE_DEFAULT_PASSWORD=
+DATABASE_DEFAULT_NAME=vix
+
+# Server configuration
+SERVER_PORT=8080
+SERVER_REQUEST_TIMEOUT=2000
+SERVER_IO_THREADS=0
+SERVER_SESSION_TIMEOUT_SEC=20
+SERVER_BENCH_MODE=false
+
+# Logging configuration
+LOGGING_ASYNC=true
+LOGGING_QUEUE_MAX=20000
+LOGGING_DROP_ON_OVERFLOW=true
+
+# WAF configuration
+WAF_MODE=basic
+WAF_MAX_TARGET_LEN=4096
+WAF_MAX_BODY_BYTES=1048576

examples/01_basic_repository.cpp

@@ -42,16 +42,12 @@ int main()
   {
     auto db = vix::db::Database::sqlite("orm_basic.db");
 
-    {
-      auto conn = db.pool().acquire();
-      conn->prepare(
-              "CREATE TABLE IF NOT EXISTS users ("
-              "id INTEGER PRIMARY KEY AUTOINCREMENT, "
-              "name TEXT NOT NULL)")
-          ->exec();
-    }
+    db.exec(
+        "CREATE TABLE IF NOT EXISTS users ("
+        "id INTEGER PRIMARY KEY AUTOINCREMENT, "
+        "name TEXT NOT NULL)");
 
-    auto repo = vix::orm::repository<User>(db, "users");
+    vix::orm::BaseRepository<User> repo(db.pool(), "users");
     const auto id = repo.create(User{0, "Alice"});
 
     std::cout << "[OK] created id=" << id << "\n";

examples/02_repository_crud.cpp

@@ -50,21 +50,18 @@ int main()
   {
     auto db = vix::db::Database::sqlite("orm_crud.db");
 
-    {
-      auto conn = db.pool().acquire();
-      conn->prepare(
-              "CREATE TABLE IF NOT EXISTS users ("
-              "id INTEGER PRIMARY KEY AUTOINCREMENT, "
-              "name TEXT NOT NULL, "
-              "email TEXT NOT NULL, "
-              "age INTEGER NOT NULL)")
-          ->exec();
-    }
+    db.exec(
+        "CREATE TABLE IF NOT EXISTS users ("
+        "id INTEGER PRIMARY KEY AUTOINCREMENT, "
+        "name TEXT NOT NULL, "
+        "email TEXT NOT NULL, "
+        "age INTEGER NOT NULL)");
 
-    auto repo = vix::orm::repository<User>(db, "users");
+    vix::orm::BaseRepository<User> repo(db.pool(), "users");
 
     const auto id = static_cast<std::int64_t>(
         repo.create(User{0, "Alice", "alice@example.com", 25}));
+
     std::cout << "[OK] create id=" << id << "\n";
 
     if (auto u = repo.findById(id))

examples/03_find_all_and_count.cpp

@@ -38,17 +38,14 @@ int main()
   {
     auto db = vix::db::Database::sqlite("orm_find_all.db");
 
-    {
-      auto conn = db.pool().acquire();
-      conn->prepare(
-              "CREATE TABLE IF NOT EXISTS users ("
-              "id INTEGER PRIMARY KEY AUTOINCREMENT, "
-              "name TEXT NOT NULL)")
-          ->exec();
-      conn->prepare("DELETE FROM users")->exec();
-    }
+    db.exec(
+        "CREATE TABLE IF NOT EXISTS users ("
+        "id INTEGER PRIMARY KEY AUTOINCREMENT, "
+        "name TEXT NOT NULL)");
+
+    db.exec("DELETE FROM users");
 
-    auto repo = vix::orm::repository<User>(db, "users");
+    vix::orm::BaseRepository<User> repo(db.pool(), "users");
     repo.create(User{0, "Alice"});
     repo.create(User{0, "Bob"});
     repo.create(User{0, "Charlie"});

examples/04_exists_and_delete.cpp

@@ -38,28 +38,29 @@ int main()
   {
     auto db = vix::db::Database::sqlite("orm_exists.db");
 
-    {
-      auto conn = db.pool().acquire();
-      conn->prepare(
-              "CREATE TABLE IF NOT EXISTS users ("
-              "id INTEGER PRIMARY KEY AUTOINCREMENT, "
-              "name TEXT NOT NULL)")
-          ->exec();
-      conn->prepare("DELETE FROM users")->exec();
-    }
-
-    auto repo = vix::orm::repository<User>(db, "users");
+    db.exec(
+        "CREATE TABLE IF NOT EXISTS users ("
+        "id INTEGER PRIMARY KEY AUTOINCREMENT, "
+        "name TEXT NOT NULL)");
+
+    db.exec("DELETE FROM users");
+
+    vix::orm::BaseRepository<User> repo(db.pool(), "users");
     const auto id = static_cast<std::int64_t>(repo.create(User{0, "Alice"}));
 
     std::cout << "[OK] exists before delete=" << (repo.existsById(id) ? "yes" : "no") << "\n";
+
     repo.removeById(id);
+
     std::cout << "[OK] exists after delete=" << (repo.existsById(id) ? "yes" : "no") << "\n";
 
     repo.create(User{0, "Bob"});
     repo.create(User{0, "Charlie"});
+
     std::cout << "[OK] count before removeAll=" << repo.count() << "\n";
 
     repo.removeAll();
+
     std::cout << "[OK] count after removeAll=" << repo.count() << "\n";
 
     return 0;

examples/05_unit_of_work.cpp

@@ -10,15 +10,11 @@ int main()
   {
     auto db = vix::db::Database::sqlite("orm_uow.db");
 
-    {
-      auto conn = db.pool().acquire();
-      conn->prepare(
-              "CREATE TABLE IF NOT EXISTS users ("
-              "id INTEGER PRIMARY KEY AUTOINCREMENT, "
-              "name TEXT NOT NULL, "
-              "age INTEGER NOT NULL)")
-          ->exec();
-    }
+    db.exec(
+        "CREATE TABLE IF NOT EXISTS users ("
+        "id INTEGER PRIMARY KEY AUTOINCREMENT, "
+        "name TEXT NOT NULL, "
+        "age INTEGER NOT NULL)");
 
     auto uow = vix::orm::unit_of_work(db);
 

examples/06_batch_insert_tx.cpp

@@ -11,15 +11,11 @@ int main()
   {
     auto db = vix::db::Database::sqlite("orm_batch.db");
 
-    {
-      auto conn = db.pool().acquire();
-      conn->prepare(
-              "CREATE TABLE IF NOT EXISTS users ("
-              "id INTEGER PRIMARY KEY AUTOINCREMENT, "
-              "name TEXT NOT NULL, "
-              "age INTEGER NOT NULL)")
-          ->exec();
-    }
+    db.exec(
+        "CREATE TABLE IF NOT EXISTS users ("
+        "id INTEGER PRIMARY KEY AUTOINCREMENT, "
+        "name TEXT NOT NULL, "
+        "age INTEGER NOT NULL)");
 
     const std::vector<std::pair<std::string, std::int64_t>> users = {
         {"Alice", 20},
@@ -28,7 +24,7 @@ int main()
         {"Diane", 35},
     };
 
-    auto uow = vix::orm::unit_of_work(db);
+    auto uow = vix::orm::UnitOfWork(db);
 
     for (const auto &[name, age] : users)
     {

examples/07_query_builder_select.cpp

@@ -10,28 +10,23 @@ int main()
   {
     auto db = vix::db::Database::sqlite("orm_qb_select.db");
 
-    {
-      auto conn = db.pool().acquire();
-      conn->prepare(
-              "CREATE TABLE IF NOT EXISTS users ("
-              "id INTEGER PRIMARY KEY AUTOINCREMENT, "
-              "name TEXT NOT NULL, "
-              "age INTEGER NOT NULL)")
-          ->exec();
-      conn->prepare("DELETE FROM users")->exec();
-
-      auto st1 = conn->prepare("INSERT INTO users (name, age) VALUES (?, ?)");
-      st1->bind(1, std::string("Alice"));
-      st1->bind(2, static_cast<std::int64_t>(20));
-      st1->exec();
-
-      auto st2 = conn->prepare("INSERT INTO users (name, age) VALUES (?, ?)");
-      st2->bind(1, std::string("Bob"));
-      st2->bind(2, static_cast<std::int64_t>(16));
-      st2->exec();
-    }
+    db.exec(
+        "CREATE TABLE IF NOT EXISTS users ("
+        "id INTEGER PRIMARY KEY AUTOINCREMENT, "
+        "name TEXT NOT NULL, "
+        "age INTEGER NOT NULL)");
+
+    db.exec("DELETE FROM users");
+
+    db.exec("INSERT INTO users (name, age) VALUES (?, ?)",
+            std::string("Alice"),
+            static_cast<std::int64_t>(20));
+
+    db.exec("INSERT INTO users (name, age) VALUES (?, ?)",
+            std::string("Bob"),
+            static_cast<std::int64_t>(16));
 
-    auto conn = db.pool().acquire();
+    vix::db::PooledConn conn(db.pool());
 
     vix::orm::QueryBuilder qb;
     qb.raw("SELECT id, name, age FROM users WHERE age >= ?")
@@ -41,7 +36,7 @@ int main()
     qb.bind(*st);
 
     auto rs = st->query();
-    while (rs->next())
+    while (rs && rs->next())
     {
       const auto &row = rs->row();
       std::cout << row.getInt64(0) << " "

examples/08_query_builder_update.cpp

@@ -10,24 +10,20 @@ int main()
   {
     auto db = vix::db::Database::sqlite("orm_qb_update.db");
 
-    {
-      auto conn = db.pool().acquire();
-      conn->prepare(
-              "CREATE TABLE IF NOT EXISTS users ("
-              "id INTEGER PRIMARY KEY AUTOINCREMENT, "
-              "name TEXT NOT NULL, "
-              "age INTEGER NOT NULL)")
-          ->exec();
-      conn->prepare("DELETE FROM users")->exec();
-
-      auto insert = conn->prepare("INSERT INTO users (name, age) VALUES (?, ?)");
-      insert->bind(1, std::string("Alice"));
-      insert->bind(2, static_cast<std::int64_t>(20));
-      insert->exec();
-    }
+    db.exec(
+        "CREATE TABLE IF NOT EXISTS users ("
+        "id INTEGER PRIMARY KEY AUTOINCREMENT, "
+        "name TEXT NOT NULL, "
+        "age INTEGER NOT NULL)");
+
+    db.exec("DELETE FROM users");
+
+    db.exec("INSERT INTO users (name, age) VALUES (?, ?)",
+            std::string("Alice"),
+            static_cast<std::int64_t>(20));
 
     {
-      auto conn = db.pool().acquire();
+      vix::db::PooledConn conn(db.pool());
 
       vix::orm::QueryBuilder qb;
       qb.raw("UPDATE users SET age = ? WHERE name = ?")
@@ -40,11 +36,9 @@ int main()
     }
 
     {
-      auto conn = db.pool().acquire();
-      auto st = conn->prepare("SELECT name, age FROM users");
-      auto rs = st->query();
+      auto rs = db.query("SELECT name, age FROM users");
 
-      while (rs->next())
+      while (rs && rs->next())
       {
         const auto &row = rs->row();
         std::cout << row.getString(0) << " " << row.getInt64(1) << "\n";

examples/09_error_handling.cpp

@@ -7,12 +7,10 @@ int main()
   try
   {
     auto db = vix::db::Database::sqlite("orm_errors.db");
-    auto conn = db.pool().acquire();
 
-    auto st = conn->prepare("SELECT * FROM table_that_does_not_exist");
-    auto rs = st->query();
+    auto rs = db.query("SELECT * FROM table_that_does_not_exist");
 
-    while (rs->next())
+    while (rs && rs->next())
     {
       (void)rs->row();
     }