Began developing the autoincr primary key

Author: liuzicheng1987

include/sqlgen/duckdb/Connection.hpp

@@ -18,19 +18,14 @@
 #include "../Transaction.hpp"
 #include "../dynamic/Write.hpp"
 #include "../internal/iterator_t.hpp"
+#include "../internal/remove_auto_incr_primary_t.hpp"
 #include "../internal/to_container.hpp"
 #include "../is_connection.hpp"
-#include "../transpilation/get_tablename.hpp"
-#include "../transpilation/has_reflection_method.hpp"
-#include "../transpilation/is_nullable.hpp"
 #include "./parsing/Parser_default.hpp"
 #include "DuckDBConnection.hpp"
 #include "Iterator.hpp"
-#include "parsing/Parser.hpp"
 #include "sqlgen/dynamic/Operation.hpp"
 #include "sqlgen/dynamic/SelectFrom.hpp"
-#include "sqlgen/transpilation/get_schema.hpp"
-#include "sqlgen/transpilation/to_table_or_query.hpp"
 #include "to_sql.hpp"
 
 namespace sqlgen::duckdb {
@@ -199,8 +194,10 @@ class Connection {
   template <class StructT>
   Result<Nothing> write_row(const StructT &_struct,
                             duckdb_appender _appender) noexcept {
+    using ViewType =
+        internal::remove_auto_incr_primary_t<rfl::view_t<const StructT>>;
     Result<Nothing> res = Nothing{};
-    rfl::to_view(_struct).apply([&](const auto &_field) {
+    ViewType(rfl::to_view(_struct)).apply([&](const auto &_field) {
       using ValueType = std::remove_cvref_t<std::remove_pointer_t<
           typename std::remove_cvref_t<decltype(_field)>::Type>>;
       if (res) {

src/sqlgen/duckdb/to_sql.cpp

@@ -673,8 +673,8 @@ std::string operation_to_sql(const dynamic::Operation& _stmt) noexcept {
 
 std::string properties_to_sql(const dynamic::types::Properties& _p) noexcept {
   return [&]() -> std::string {
-    return std::string(_p.auto_incr ? " GENERATED ALWAYS AS IDENTITY" : "") +
-           std::string(_p.nullable ? "" : " NOT NULL") +
+    return std::string(_p.nullable ? "" : " NOT NULL") +
+           std::string(_p.auto_incr ? " GENERATED ALWAYS" : "") +
            std::string(_p.unique ? " UNIQUE" : "");
   }() + [&]() -> std::string {
     if (!_p.foreign_key_reference) {

tests/duckdb/test_auto_incr_primary_key.cpp

@@ -0,0 +1,45 @@
+#include <gtest/gtest.h>
+
+#include <rfl.hpp>
+#include <rfl/json.hpp>
+#include <sqlgen.hpp>
+#include <sqlgen/duckdb.hpp>
+#include <vector>
+
+namespace test_auto_incr_primary_key {
+
+struct Person {
+  sqlgen::PrimaryKey<uint32_t, sqlgen::auto_incr> id;
+  std::string first_name;
+  std::string last_name;
+  int age;
+};
+
+TEST(duckdb, test_auto_incr_primary_key) {
+  auto people1 = std::vector<Person>(
+      {Person{.first_name = "Homer", .last_name = "Simpson", .age = 45},
+       Person{.first_name = "Bart", .last_name = "Simpson", .age = 10},
+       Person{.first_name = "Lisa", .last_name = "Simpson", .age = 8},
+       Person{.first_name = "Maggie", .last_name = "Simpson", .age = 0}});
+
+  using namespace sqlgen;
+  using namespace sqlgen::literals;
+
+  const auto people2 = duckdb::connect()
+                           .and_then(write(std::ref(people1)))
+                           .and_then(sqlgen::read<std::vector<Person>> |
+                                     order_by("age"_c.desc()))
+                           .value();
+
+  people1.at(0).id = 1;
+  people1.at(1).id = 2;
+  people1.at(2).id = 3;
+  people1.at(3).id = 4;
+
+  const auto json1 = rfl::json::write(people1);
+  const auto json2 = rfl::json::write(people2);
+
+  EXPECT_EQ(json1, json2);
+}
+
+}  // namespace test_auto_incr_primary_key