/* * Copyright (c) 2013-2015, Roland Bock * All rights reserved. * * Redistribution and use in source and binary forms, with or without modification, * are permitted provided that the following conditions are met: * * Redistributions of source code must retain the above copyright notice, this * list of conditions and the following disclaimer. * * Redistributions in binary form must reproduce the above copyright notice, this * list of conditions and the following disclaimer in the documentation and/or * other materials provided with the distribution. * * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE * DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE FOR * ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON * ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. */ #ifndef SQLPP_DATABASE_CONNECTION_H #define SQLPP_DATABASE_CONNECTION_H #include #include #include // You may use char result or bind result or both #include // to represent results of select and prepared select namespace sqlpp { namespace database { // The context is not a requirement, but if the database requires // any deviations from the SQL standard, you should use your own // context in order to specialize the behaviour, see also interpreter.h struct context_t { template std::ostream& operator<<(T t); std::string escape(std::string arg); }; class connection: public sqlpp::connection // this inheritance helps with ADL for dynamic_select, for instance { public: using _traits = ::sqlpp::make_traits<::sqlpp::no_value_t, ::sqlpp::tag::enforce_null_result_treatment // If that is what you really want, leave it out otherwise >; using _prepared_statement_t = << handle to a prepared statement of the database >>; using _serializer_context_t = << This context is used to serialize a statement >> using _interpreter_context_t = << This context is used interpret a statement >>; // serializer and interpreter are typically the same for string based connectors // the types are required for dynamic statement components, see sqlpp11/interpretable.h connection(...); ~connection(); connection(const connection&) = delete; connection(connection&&) = delete; connection& operator=(const connection&) = delete; connection& operator=(connection&&) = delete; //! "direct" select template <> select(const Select& s); //! prepared select template _prepared_statement_t prepare_select(Select& s); template <> run_prepared_select(const PreparedSelect& s); // call s._bind_params() //! "direct insert template size_t insert(const Insert& i); //! prepared insert template _prepared_statement_t prepare_insert(Insert& i); template size_t run_prepared_insert(const PreparedInsert& i); // call i._bind_params() //! "direct" update template size_t update(const Update& u); //! "prepared" update template _prepared_statement_t prepare_update(Update& u); template size_t run_prepared_update(const PreparedUpdate& u); // call u._bind_params() //! "direct" remove template size_t remove(const Remove& r) //! prepared remove template _prepared_statement_t prepare_remove(Remove& r); template size_t run_prepared_remove(const PreparedRemove& r); // call r._bind_params() //! call run on the argument template auto operator() (const T& t) -> decltype(t._run(*this)) { return t._run(*this); } //! call prepare on the argument template auto prepare(const T& t) -> decltype(t._prepare(*this)) { return t._prepare(*this); } //! start transaction void start_transaction(); //! commit transaction (or throw transaction if the transaction has been finished already) void commit_transaction(); //! rollback transaction with or without reporting the rollback (or throw if the transaction has been finished already) void rollback_transaction(bool report); //! report a rollback failure (will be called by transactions in case of a rollback failure in the destructor) void report_rollback_failure(const std::string message) noexcept; }; } } #include #endif