LeechCraft  0.6.70-13729-g7046a9d2a7
Modular cross-platform feature rich live environment.
pgimpl.h
Go to the documentation of this file.
1 /**********************************************************************
2  * LeechCraft - modular cross-platform feature rich internet client.
3  * Copyright (C) 2006-2014 Georg Rudoy
4  *
5  * Boost Software License - Version 1.0 - August 17th, 2003
6  *
7  * Permission is hereby granted, free of charge, to any person or organization
8  * obtaining a copy of the software and accompanying documentation covered by
9  * this license (the "Software") to use, reproduce, display, distribute,
10  * execute, and transmit the Software, and to prepare derivative works of the
11  * Software, and to permit third-parties to whom the Software is furnished to
12  * do so, all subject to the following:
13  *
14  * The copyright notices in the Software and this entire statement, including
15  * the above license grant, this restriction and the following disclaimer,
16  * must be included in all copies of the Software, in whole or in part, and
17  * all derivative works of the Software, unless such copies or derivative
18  * works are solely in the form of machine-executable object code generated by
19  * a source language processor.
20  *
21  * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
22  * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
23  * FITNESS FOR A PARTICULAR PURPOSE, TITLE AND NON-INFRINGEMENT. IN NO EVENT
24  * SHALL THE COPYRIGHT HOLDERS OR ANYONE DISTRIBUTING THE SOFTWARE BE LIABLE
25  * FOR ANY DAMAGES OR OTHER LIABILITY, WHETHER IN CONTRACT, TORT OR OTHERWISE,
26  * ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
27  * DEALINGS IN THE SOFTWARE.
28  **********************************************************************/
29 
30 #pragma once
31 
32 #include <util/sll/visitor.h>
33 #include "oraltypes.h"
34 #include "oraldetailfwd.h"
35 #include "impldefs.h"
36 
38 {
39  using QSqlQuery_ptr = std::shared_ptr<QSqlQuery>;
40 
42  {
43  const QSqlDatabase DB_;
44 
45  QSqlQuery_ptr Default_;
46  QSqlQuery_ptr Ignore_;
47 
48  const QString InsertBase_;
49  const QString Updater_;
50  public:
51  InsertQueryBuilder (const QSqlDatabase& db, const CachedFieldsData& data)
52  : DB_ { db }
53  , InsertBase_ { "INSERT INTO " + data.Table_ +
54  " (" + data.Fields_.join (", ") + ") VALUES (" +
55  data.BoundFields_.join (", ") + ") " }
56  , Updater_ { Map (data.Fields_, [] (auto&& str) { return str + " = EXCLUDED." + str; }).join (", ") }
57  {
58  }
59 
61  {
62  return Visit (action.Selector_,
63  [this] (InsertAction::DefaultTag) { return GetDefaultQuery (); },
64  [this] (InsertAction::IgnoreTag) { return GetIgnoreQuery (); },
65  [this] (InsertAction::Replace ct) { return MakeReplaceQuery (ct.Fields_); });
66  }
67  private:
68  QSqlQuery_ptr GetDefaultQuery ()
69  {
70  if (!Default_)
71  {
72  Default_ = std::make_shared<QSqlQuery> (DB_);
73  Default_->prepare (InsertBase_);
74  }
75  return Default_;
76  }
77 
78  QSqlQuery_ptr GetIgnoreQuery ()
79  {
80  if (!Default_)
81  {
82  Default_ = std::make_shared<QSqlQuery> (DB_);
83  Default_->prepare (InsertBase_ + "ON CONFLICT DO NOTHING");
84  }
85  return Default_;
86  }
87 
88  QSqlQuery_ptr MakeReplaceQuery (const QStringList& constraining)
89  {
90  auto query = std::make_shared<QSqlQuery> (DB_);
91  query->prepare (InsertBase_ + GetReplacer (constraining));
92  return query;
93  }
94 
95  QString GetReplacer (const QStringList& constraining) const
96  {
97  return "ON CONFLICT (" +
98  constraining.join (", ") +
99  ") DO UPDATE SET " +
100  Updater_;
101  }
102  };
103 
105  {
106  public:
107  struct TypeLits
108  {
109  inline static const QString IntAutoincrement { "SERIAL PRIMARY KEY" };
110  inline static const QString Binary { "BYTEA" };
111  };
112 
113  inline static const QString LimitNone { "ALL" };
114 
115  auto MakeInsertQueryBuilder (const QSqlDatabase& db, const CachedFieldsData& data) const
116  {
117  return std::make_unique<InsertQueryBuilder> (db, data);
118  }
119  };
120 }
121 
122 namespace LC::Util::oral
123 {
125 }
InsertQueryBuilder(const QSqlDatabase &db, const CachedFieldsData &data)
Definition: pgimpl.h:51
QSqlQuery_ptr GetQuery(InsertAction action) override
Definition: pgimpl.h:60
auto Visit(const Either< Left, Right > &either, Args &&... args)
Definition: either.h:224
std::shared_ptr< QSqlQuery > QSqlQuery_ptr
Definition: oral.h:73
std::shared_ptr< QSqlQuery > QSqlQuery_ptr
Definition: pgimpl.h:39
auto Map(Container &&c, F f)
Definition: prelude.h:164
ActionSelector_t Selector_
Definition: oraltypes.h:221
auto MakeInsertQueryBuilder(const QSqlDatabase &db, const CachedFieldsData &data) const
Definition: pgimpl.h:115