From a87c149915fa5a262bd797df1c2a4e756420d413 Mon Sep 17 00:00:00 2001
From: Boris Kolpackov <boris@codesynthesis.com>
Date: Mon, 21 Jun 2021 12:52:18 +0200
Subject: Add support for bulk operations in PostgreSQL 14

---
 odb/relational/pgsql/context.cxx |  2 +-
 odb/relational/pgsql/header.cxx  | 14 ++++++++++++++
 odb/relational/pgsql/source.cxx  |  6 +++---
 3 files changed, 18 insertions(+), 4 deletions(-)

(limited to 'odb/relational/pgsql')

diff --git a/odb/relational/pgsql/context.cxx b/odb/relational/pgsql/context.cxx
index a9f34dd..7f99f5d 100644
--- a/odb/relational/pgsql/context.cxx
+++ b/odb/relational/pgsql/context.cxx
@@ -85,7 +85,7 @@ namespace relational
       insert_send_auto_id = false;
       delay_freeing_statement_result = false;
       need_image_clone = false;
-      generate_bulk = false;
+      generate_bulk = true;
       global_index = true;
       global_fkey = false;
       data_->bind_vector_ = "pgsql::bind*";
diff --git a/odb/relational/pgsql/header.cxx b/odb/relational/pgsql/header.cxx
index ff00eaa..c3efc3e 100644
--- a/odb/relational/pgsql/header.cxx
+++ b/odb/relational/pgsql/header.cxx
@@ -87,6 +87,20 @@ namespace relational
           }
 
           os << endl;
+
+          if (poly_derived)
+            return;
+
+          // Bulk operations batch size.
+          //
+          {
+            unsigned long long b (c.count ("bulk")
+                                  ? c.get<unsigned long long> ("bulk")
+                                  : 1);
+
+            os << "static const std::size_t batch = " << b << "UL;"
+               << endl;
+          }
         }
 
         virtual void
diff --git a/odb/relational/pgsql/source.cxx b/odb/relational/pgsql/source.cxx
index 580103d..b881e48 100644
--- a/odb/relational/pgsql/source.cxx
+++ b/odb/relational/pgsql/source.cxx
@@ -203,7 +203,7 @@ namespace relational
         traverse_numeric (member_info& mi)
         {
           os << b << ".type = pgsql::bind::numeric;"
-             << b << ".buffer = " << arg << "." << mi.var << "value.data ();"
+             << b << ".buffer = " << arg << "." << mi.var << "value.data_ptr ();"
              << b << ".capacity = " << arg << "." << mi.var <<
             "value.capacity ();"
              << b << ".size = &" << arg << "." << mi.var << "size;"
@@ -224,7 +224,7 @@ namespace relational
         {
           os << b << ".type = " <<
             char_bin_buffer_types[mi.st->type - sql_type::CHAR] << ";"
-             << b << ".buffer = " << arg << "." << mi.var << "value.data ();"
+             << b << ".buffer = " << arg << "." << mi.var << "value.data_ptr ();"
              << b << ".capacity = " << arg << "." << mi.var <<
             "value.capacity ();"
              << b << ".size = &" << arg << "." << mi.var << "size;"
@@ -245,7 +245,7 @@ namespace relational
         traverse_varbit (member_info& mi)
         {
           os << b << ".type = pgsql::bind::varbit;"
-             << b << ".buffer = " << arg << "." << mi.var << "value.data ();"
+             << b << ".buffer = " << arg << "." << mi.var << "value.data_ptr ();"
              << b << ".capacity = " << arg << "." << mi.var <<
             "value.capacity ();"
              << b << ".size = &" << arg << "." << mi.var << "size;"
-- 
cgit v1.1