src/config/sqlite3/statement.cpp

   1 /*
   2  *  Copyright (c) 2014 Samsung Electronics Co., Ltd All Rights Reserved
   3  *
   4  *  Contact: Jan Olszak <j.olszak@samsung.com>
   5  *
   6  *  Licensed under the Apache License, Version 2.0 (the "License");
   7  *  you may not use this file except in compliance with the License.
   8  *  You may obtain a copy of the License at
   9  *
  10  *      http://www.apache.org/licenses/LICENSE-2.0
  11  *
  12  *  Unless required by applicable law or agreed to in writing, software
  13  *  distributed under the License is distributed on an "AS IS" BASIS,
  14  *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  15  *  See the License for the specific language governing permissions and
  16  *  limitations under the License
  17  */
  18
  19 /**
  20  * @file
  21  * @author Jan Olszak (j.olszak@samsung.com)
  22  * @brief  Definition of the class managing a sqlite3 statement
  23  */
  24
  25 #include "config/sqlite3/statement.hpp"
  26 #include "config/exception.hpp"
  27
  28
  29 namespace config {
  30 namespace sqlite3 {
  31
  32 Statement::Statement(sqlite3::Connection& connRef, const std::string& query)
  33     : mConnRef(connRef)
  34 {
  35     if (::sqlite3_prepare_v2(connRef.get(),
  36                              query.c_str(),
  37                              query.size(),
  38                              &mStmtPtr,
  39                              NULL)
  40             != SQLITE_OK) {
  41         throw ConfigException("Error during preparing statement " +
  42                               mConnRef.getErrorMessage());
  43     }
  44
  45     if (mStmtPtr == NULL) {
  46         throw ConfigException("Wrong query: " + query);
  47     }
  48 }
  49
  50 Statement::Statement::~Statement()
  51 {
  52     if (::sqlite3_finalize(mStmtPtr) != SQLITE_OK) {
  53         throw ConfigException("Error during finalizing statement " +
  54                               mConnRef.getErrorMessage());
  55     }
  56 }
  57
  58 sqlite3_stmt* Statement::get()
  59 {
  60     return mStmtPtr;
  61 }
  62
  63 void Statement::reset()
  64 {
  65     if (::sqlite3_clear_bindings(mStmtPtr) != SQLITE_OK) {
  66         throw ConfigException("Error unbinding statement: " +
  67                               mConnRef.getErrorMessage());
  68     }
  69
  70     if (::sqlite3_reset(mStmtPtr) != SQLITE_OK) {
  71         throw ConfigException("Error reseting statement: " +
  72                               mConnRef.getErrorMessage());
  73     }
  74 }
  75
  76 } // namespace sqlite3
  77 } // namespace config