Add beast_sqdb module

2025-11-28 06:55:50 +00:00 · 2013-07-24 03:07:50 -07:00
parent cb6bc22b6c
commit ece44f5886
36 changed files with 4985 additions and 0 deletions
--- a/Subtrees/beast/modules/beast_sqdb/source/ref_counted_statement.cpp
+++ b/Subtrees/beast/modules/beast_sqdb/source/ref_counted_statement.cpp
@@ -0,0 +1,127 @@
+//------------------------------------------------------------------------------
+/*
+    This file is part of Beast: https://github.com/vinniefalco/Beast
+    Copyright 2013, Vinnie Falco <vinnie.falco@gmail.com>
+
+    Permission to use, copy, modify, and/or distribute this software for any
+    purpose  with  or without fee is hereby granted, provided that the above
+    copyright notice and this permission notice appear in all copies.
+
+    THE  SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
+    WITH  REGARD  TO  THIS  SOFTWARE  INCLUDING  ALL  IMPLIED  WARRANTIES  OF
+    MERCHANTABILITY  AND  FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
+    ANY  SPECIAL ,  DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
+    WHATSOEVER  RESULTING  FROM  LOSS  OF USE, DATA OR PROFITS, WHETHER IN AN
+    ACTION  OF  CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
+    OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
+
+    Portions based on SOCI - The C++ Database Access Library: 
+
+    SOCI: http://soci.sourceforge.net/
+
+    This file incorporates work covered by the following copyright
+    and permission notice:
+
+    Copyright (C) 2004 Maciej Sobczak, Stephen Hutton, Mateusz Loskot,
+    Pawel Aleksander Fedorynski, David Courtney, Rafal Bobrowski,
+    Julian Taylor, Henning Basold, Ilia Barahovski, Denis Arnaud,
+    Daniel Lidstr<74>m, Matthieu Kermagoret, Artyom Beilis, Cory Bennett,
+    Chris Weed, Michael Davidsaver, Jakub Stachowski, Alex Ott, Rainer Bauer,
+    Martin Muenstermann, Philip Pemberton, Eli Green, Frederic Chateau,
+    Artyom Tonkikh, Roger Orr, Robert Massaioli, Sergey Nikulov,
+    Shridhar Daithankar, S<>ren Meyer-Eppler, Mario Valesco.
+
+    Boost Software License - Version 1.0, August 17th, 2003
+
+    Permission is hereby granted, free of charge, to any person or organization
+    obtaining a copy of the software and accompanying documentation covered by
+    this license (the "Software") to use, reproduce, display, distribute,
+    execute, and transmit the Software, and to prepare derivative works of the
+    Software, and to permit third-parties to whom the Software is furnished to
+    do so, all subject to the following:
+
+    The copyright notices in the Software and this entire statement, including
+    the above license grant, this restriction and the following disclaimer,
+    must be included in all copies of the Software, in whole or in part, and
+    all derivative works of the Software, unless such copies or derivative
+    works are solely in the form of machine-executable object code generated by
+    a source language processor.
+
+    THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+    IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+    FITNESS FOR A PARTICULAR PURPOSE, TITLE AND NON-INFRINGEMENT. IN NO EVENT
+    SHALL THE COPYRIGHT HOLDERS OR ANYONE DISTRIBUTING THE SOFTWARE BE LIABLE
+    FOR ANY DAMAGES OR OTHER LIABILITY, WHETHER IN CONTRACT, TORT OR OTHERWISE,
+    ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
+    DEALINGS IN THE SOFTWARE.
+*/
+//==============================================================================
+
+namespace sqdb
+{
+
+namespace detail
+{
+
+ref_counted_statement_base::ref_counted_statement_base(session& s)
+    : m_refs(1)
+    , m_session(s)
+{
+}
+
+ref_counted_statement_base ::~ref_counted_statement_base()
+{
+}
+
+void ref_counted_statement_base::addref()
+{
+    ++m_refs;
+}
+
+void ref_counted_statement_base::release()
+{
+    if (--m_refs == 0)
+    {
+        final_action();
+        delete this;
+    }
+}
+
+std::ostringstream& ref_counted_statement_base::get_query_stream()
+{
+    return m_session.get_query_stream();
+}
+
+//------------------------------------------------------------------------------
+
+ref_counted_statement::ref_counted_statement(session& s, Error& error)
+    : ref_counted_statement_base(s)
+    , m_error(error)
+    , m_st(s)
+{
+}
+
+void ref_counted_statement::exchange(into_type_ptr const& i)
+{
+    m_st.exchange(i);
+}
+
+void ref_counted_statement::exchange(use_type_ptr const& u)
+{
+    m_st.exchange(u);
+}
+
+void ref_counted_statement::final_action()
+{
+    m_st.prepare(m_session.get_query_stream().str(), false);
+
+    Error error;
+    m_st.execute_and_fetch(error);
+    m_error = error;
+
+    m_st.clean_up();
+}
+
+}
+
+}