123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780 |
- #include <sqlite3.h>
- #include <string>
- #include <vector>
- #include <boost/foreach.hpp>
- #include <datasrc/sqlite3_accessor.h>
- #include <datasrc/logger.h>
- #include <datasrc/data_source.h>
- #include <datasrc/factory.h>
- #include <util/filename.h>
- using namespace std;
- using namespace isc::data;
- #define SQLITE_SCHEMA_VERSION 1
- #define CONFIG_ITEM_DATABASE_FILE "database_file"
- namespace isc {
- namespace datasrc {
- enum StatementID {
- ZONE = 0,
- ANY = 1,
- ANY_SUB = 2,
- BEGIN = 3,
- COMMIT = 4,
- ROLLBACK = 5,
- DEL_ZONE_RECORDS = 6,
- ADD_RECORD = 7,
- DEL_RECORD = 8,
- ITERATE = 9,
- FIND_PREVIOUS = 10,
- NUM_STATEMENTS = 11
- };
- const char* const text_statements[NUM_STATEMENTS] = {
-
-
- "SELECT id FROM zones WHERE name=?1 AND rdclass = ?2",
- "SELECT rdtype, ttl, sigtype, rdata FROM records "
- "WHERE zone_id=?1 AND name=?2",
- "SELECT rdtype, ttl, sigtype, rdata "
- "FROM records WHERE zone_id=?1 AND name LIKE (\"%.\" || ?2)",
- "BEGIN",
- "COMMIT",
- "ROLLBACK",
- "DELETE FROM records WHERE zone_id=?1",
- "INSERT INTO records "
- "(zone_id, name, rname, ttl, rdtype, sigtype, rdata) "
- "VALUES (?1, ?2, ?3, ?4, ?5, ?6, ?7)",
- "DELETE FROM records WHERE zone_id=?1 AND name=?2 "
- "AND rdtype=?3 AND rdata=?4",
- "SELECT rdtype, ttl, sigtype, rdata, name FROM records "
- "WHERE zone_id = ?1 ORDER BY name, rdtype",
-
- "SELECT name FROM records "
- "WHERE zone_id=?1 AND rdtype = 'NSEC' AND "
- "rname < $2 ORDER BY rname DESC LIMIT 1"
- };
- struct SQLite3Parameters {
- SQLite3Parameters() :
- db_(NULL), version_(-1), updating_zone(false), updated_zone_id(-1)
- {
- for (int i = 0; i < NUM_STATEMENTS; ++i) {
- statements_[i] = NULL;
- }
- }
- sqlite3* db_;
- int version_;
- sqlite3_stmt* statements_[NUM_STATEMENTS];
- bool updating_zone;
- int updated_zone_id;
- };
- class StatementProcessor {
- public:
-
-
- StatementProcessor(SQLite3Parameters& dbparameters, StatementID stmt_id,
- const char* desc) :
- dbparameters_(dbparameters), stmt_id_(stmt_id), desc_(desc)
- {
- sqlite3_clear_bindings(dbparameters_.statements_[stmt_id_]);
- }
- ~StatementProcessor() {
- sqlite3_reset(dbparameters_.statements_[stmt_id_]);
- }
- void exec() {
- if (sqlite3_step(dbparameters_.statements_[stmt_id_]) != SQLITE_DONE) {
- sqlite3_reset(dbparameters_.statements_[stmt_id_]);
- isc_throw(DataSourceError, "failed to " << desc_ << ": " <<
- sqlite3_errmsg(dbparameters_.db_));
- }
- }
- private:
- SQLite3Parameters& dbparameters_;
- const StatementID stmt_id_;
- const char* const desc_;
- };
- SQLite3Accessor::SQLite3Accessor(const std::string& filename,
- const string& rrclass) :
- dbparameters_(new SQLite3Parameters),
- filename_(filename),
- class_(rrclass),
- database_name_("sqlite3_" +
- isc::util::Filename(filename).nameAndExtension())
- {
- LOG_DEBUG(logger, DBG_TRACE_BASIC, DATASRC_SQLITE_NEWCONN);
- open(filename);
- }
- boost::shared_ptr<DatabaseAccessor>
- SQLite3Accessor::clone() {
- return (boost::shared_ptr<DatabaseAccessor>(new SQLite3Accessor(filename_,
- class_)));
- }
- namespace {
- class Initializer {
- public:
- ~Initializer() {
- for (int i = 0; i < NUM_STATEMENTS; ++i) {
- sqlite3_finalize(params_.statements_[i]);
- }
- if (params_.db_ != NULL) {
- sqlite3_close(params_.db_);
- }
- }
- void move(SQLite3Parameters* dst) {
- *dst = params_;
- params_ = SQLite3Parameters();
- }
- SQLite3Parameters params_;
- };
- const char* const SCHEMA_LIST[] = {
- "CREATE TABLE schema_version (version INTEGER NOT NULL)",
- "INSERT INTO schema_version VALUES (1)",
- "CREATE TABLE zones (id INTEGER PRIMARY KEY, "
- "name STRING NOT NULL COLLATE NOCASE, "
- "rdclass STRING NOT NULL COLLATE NOCASE DEFAULT 'IN', "
- "dnssec BOOLEAN NOT NULL DEFAULT 0)",
- "CREATE INDEX zones_byname ON zones (name)",
- "CREATE TABLE records (id INTEGER PRIMARY KEY, "
- "zone_id INTEGER NOT NULL, name STRING NOT NULL COLLATE NOCASE, "
- "rname STRING NOT NULL COLLATE NOCASE, ttl INTEGER NOT NULL, "
- "rdtype STRING NOT NULL COLLATE NOCASE, sigtype STRING COLLATE NOCASE, "
- "rdata STRING NOT NULL)",
- "CREATE INDEX records_byname ON records (name)",
- "CREATE INDEX records_byrname ON records (rname)",
- "CREATE TABLE nsec3 (id INTEGER PRIMARY KEY, zone_id INTEGER NOT NULL, "
- "hash STRING NOT NULL COLLATE NOCASE, "
- "owner STRING NOT NULL COLLATE NOCASE, "
- "ttl INTEGER NOT NULL, rdtype STRING NOT NULL COLLATE NOCASE, "
- "rdata STRING NOT NULL)",
- "CREATE INDEX nsec3_byhash ON nsec3 (hash)",
- NULL
- };
- sqlite3_stmt*
- prepare(sqlite3* const db, const char* const statement) {
- sqlite3_stmt* prepared = NULL;
- if (sqlite3_prepare_v2(db, statement, -1, &prepared, NULL) != SQLITE_OK) {
- isc_throw(SQLite3Error, "Could not prepare SQLite statement: " <<
- statement);
- }
- return (prepared);
- }
- void doSleep() {
- struct timespec req;
- req.tv_sec = 0;
- req.tv_nsec = 100000000;
- nanosleep(&req, NULL);
- }
- int checkSchemaVersion(sqlite3* db) {
- sqlite3_stmt* prepared = NULL;
-
-
-
- for (size_t i = 0; i < 50; ++i) {
- int rc = sqlite3_prepare_v2(db, "SELECT version FROM schema_version",
- -1, &prepared, NULL);
- if (rc == SQLITE_ERROR) {
-
-
- return (-1);
- } else if (rc == SQLITE_OK) {
- break;
- } else if (rc != SQLITE_BUSY || i == 50) {
- isc_throw(SQLite3Error, "Unable to prepare version query: "
- << rc << " " << sqlite3_errmsg(db));
- }
- doSleep();
- }
- if (sqlite3_step(prepared) != SQLITE_ROW) {
- isc_throw(SQLite3Error,
- "Unable to query version: " << sqlite3_errmsg(db));
- }
- int version = sqlite3_column_int(prepared, 0);
- sqlite3_finalize(prepared);
- return (version);
- }
- int create_database(sqlite3* db) {
-
-
-
-
- int rc;
- logger.info(DATASRC_SQLITE_SETUP);
- for (size_t i = 0; i < 50; ++i) {
- rc = sqlite3_exec(db, "BEGIN EXCLUSIVE TRANSACTION", NULL, NULL,
- NULL);
- if (rc == SQLITE_OK) {
- break;
- } else if (rc != SQLITE_BUSY || i == 50) {
- isc_throw(SQLite3Error, "Unable to acquire exclusive lock "
- "for database creation: " << sqlite3_errmsg(db));
- }
- doSleep();
- }
- int schema_version = checkSchemaVersion(db);
- if (schema_version == -1) {
- for (int i = 0; SCHEMA_LIST[i] != NULL; ++i) {
- if (sqlite3_exec(db, SCHEMA_LIST[i], NULL, NULL, NULL) !=
- SQLITE_OK) {
- isc_throw(SQLite3Error,
- "Failed to set up schema " << SCHEMA_LIST[i]);
- }
- }
- sqlite3_exec(db, "COMMIT TRANSACTION", NULL, NULL, NULL);
- return (SQLITE_SCHEMA_VERSION);
- } else {
- return (schema_version);
- }
- }
- void
- checkAndSetupSchema(Initializer* initializer) {
- sqlite3* const db = initializer->params_.db_;
- int schema_version = checkSchemaVersion(db);
- if (schema_version != SQLITE_SCHEMA_VERSION) {
- schema_version = create_database(db);
- }
- initializer->params_.version_ = schema_version;
- for (int i = 0; i < NUM_STATEMENTS; ++i) {
- initializer->params_.statements_[i] = prepare(db, text_statements[i]);
- }
- }
- }
- void
- SQLite3Accessor::open(const std::string& name) {
- LOG_DEBUG(logger, DBG_TRACE_BASIC, DATASRC_SQLITE_CONNOPEN).arg(name);
- if (dbparameters_->db_ != NULL) {
-
- isc_throw(DataSourceError, "Duplicate SQLite open with " << name);
- }
- Initializer initializer;
- if (sqlite3_open(name.c_str(), &initializer.params_.db_) != 0) {
- isc_throw(SQLite3Error, "Cannot open SQLite database file: " << name);
- }
- checkAndSetupSchema(&initializer);
- initializer.move(dbparameters_.get());
- }
- SQLite3Accessor::~SQLite3Accessor() {
- LOG_DEBUG(logger, DBG_TRACE_BASIC, DATASRC_SQLITE_DROPCONN);
- if (dbparameters_->db_ != NULL) {
- close();
- }
- }
- void
- SQLite3Accessor::close(void) {
- LOG_DEBUG(logger, DBG_TRACE_BASIC, DATASRC_SQLITE_CONNCLOSE);
- if (dbparameters_->db_ == NULL) {
- isc_throw(DataSourceError,
- "SQLite data source is being closed before open");
- }
-
- for (int i = 0; i < NUM_STATEMENTS; ++i) {
- sqlite3_finalize(dbparameters_->statements_[i]);
- dbparameters_->statements_[i] = NULL;
- }
- sqlite3_close(dbparameters_->db_);
- dbparameters_->db_ = NULL;
- }
- std::pair<bool, int>
- SQLite3Accessor::getZone(const std::string& name) const {
- int rc;
- sqlite3_stmt* const stmt = dbparameters_->statements_[ZONE];
-
-
- sqlite3_reset(stmt);
- rc = sqlite3_bind_text(stmt, 1, name.c_str(), -1, SQLITE_STATIC);
- if (rc != SQLITE_OK) {
- isc_throw(SQLite3Error, "Could not bind " << name <<
- " to SQL statement (zone)");
- }
- rc = sqlite3_bind_text(stmt, 2, class_.c_str(), -1, SQLITE_STATIC);
- if (rc != SQLITE_OK) {
- isc_throw(SQLite3Error, "Could not bind " << class_ <<
- " to SQL statement (zone)");
- }
-
- rc = sqlite3_step(stmt);
- if (rc == SQLITE_ROW) {
- const int zone_id = sqlite3_column_int(stmt, 0);
- sqlite3_reset(stmt);
- return (pair<bool, int>(true, zone_id));
- } else if (rc == SQLITE_DONE) {
-
- sqlite3_reset(stmt);
- return (pair<bool, int>(false, 0));
- }
- sqlite3_reset(stmt);
- isc_throw(DataSourceError, "Unexpected failure in sqlite3_step: " <<
- sqlite3_errmsg(dbparameters_->db_));
-
- return (std::pair<bool, int>(false, 0));
- }
- namespace {
- const char*
- convertToPlainChar(const unsigned char* ucp, sqlite3 *db) {
- if (ucp == NULL) {
-
-
-
- if (sqlite3_errcode(db) == SQLITE_NOMEM) {
- isc_throw(DataSourceError,
- "Sqlite3 backend encountered a memory allocation "
- "error in sqlite3_column_text()");
- } else {
- return ("");
- }
- }
- const void* p = ucp;
- return (static_cast<const char*>(p));
- }
- }
- class SQLite3Accessor::Context : public DatabaseAccessor::IteratorContext {
- public:
-
-
- Context(const boost::shared_ptr<const SQLite3Accessor>& accessor, int id) :
- iterator_type_(ITT_ALL),
- accessor_(accessor),
- statement_(NULL),
- name_("")
- {
-
- statement_ = prepare(accessor->dbparameters_->db_,
- text_statements[ITERATE]);
- bindZoneId(id);
- }
-
-
- Context(const boost::shared_ptr<const SQLite3Accessor>& accessor, int id,
- const std::string& name, bool subdomains) :
- iterator_type_(ITT_NAME),
- accessor_(accessor),
- statement_(NULL),
- name_(name)
- {
-
- statement_ = prepare(accessor->dbparameters_->db_,
- subdomains ? text_statements[ANY_SUB] :
- text_statements[ANY]);
- bindZoneId(id);
- bindName(name_);
- }
- bool getNext(std::string (&data)[COLUMN_COUNT]) {
-
-
-
- if (statement_ == NULL) {
- return false;
- }
- const int rc(sqlite3_step(statement_));
- if (rc == SQLITE_ROW) {
-
- copyColumn(data, TYPE_COLUMN);
- copyColumn(data, TTL_COLUMN);
- copyColumn(data, SIGTYPE_COLUMN);
- copyColumn(data, RDATA_COLUMN);
-
- if (iterator_type_ == ITT_ALL) {
- copyColumn(data, NAME_COLUMN);
- }
- return (true);
- } else if (rc != SQLITE_DONE) {
- isc_throw(DataSourceError,
- "Unexpected failure in sqlite3_step: " <<
- sqlite3_errmsg(accessor_->dbparameters_->db_));
- }
- finalize();
- return (false);
- }
- virtual ~Context() {
- finalize();
- }
- private:
-
-
-
- enum IteratorType {
- ITT_ALL,
- ITT_NAME
- };
- void copyColumn(std::string (&data)[COLUMN_COUNT], int column) {
- data[column] = convertToPlainChar(sqlite3_column_text(statement_,
- column),
- accessor_->dbparameters_->db_);
- }
- void bindZoneId(const int zone_id) {
- if (sqlite3_bind_int(statement_, 1, zone_id) != SQLITE_OK) {
- finalize();
- isc_throw(SQLite3Error, "Could not bind int " << zone_id <<
- " to SQL statement: " <<
- sqlite3_errmsg(accessor_->dbparameters_->db_));
- }
- }
- void bindName(const std::string& name) {
- if (sqlite3_bind_text(statement_, 2, name.c_str(), -1,
- SQLITE_TRANSIENT) != SQLITE_OK) {
- const char* errmsg = sqlite3_errmsg(accessor_->dbparameters_->db_);
- finalize();
- isc_throw(SQLite3Error, "Could not bind text '" << name <<
- "' to SQL statement: " << errmsg);
- }
- }
- void finalize() {
- sqlite3_finalize(statement_);
- statement_ = NULL;
- }
- const IteratorType iterator_type_;
- boost::shared_ptr<const SQLite3Accessor> accessor_;
- sqlite3_stmt *statement_;
- const std::string name_;
- };
- DatabaseAccessor::IteratorContextPtr
- SQLite3Accessor::getRecords(const std::string& name, int id,
- bool subdomains) const
- {
- return (IteratorContextPtr(new Context(shared_from_this(), id, name,
- subdomains)));
- }
- DatabaseAccessor::IteratorContextPtr
- SQLite3Accessor::getAllRecords(int id) const {
- return (IteratorContextPtr(new Context(shared_from_this(), id)));
- }
- pair<bool, int>
- SQLite3Accessor::startUpdateZone(const string& zone_name, const bool replace) {
- if (dbparameters_->updating_zone) {
- isc_throw(DataSourceError,
- "duplicate zone update on SQLite3 data source");
- }
- const pair<bool, int> zone_info(getZone(zone_name));
- if (!zone_info.first) {
- return (zone_info);
- }
- StatementProcessor(*dbparameters_, BEGIN,
- "start an SQLite3 transaction").exec();
- if (replace) {
- try {
- StatementProcessor delzone_exec(*dbparameters_, DEL_ZONE_RECORDS,
- "delete zone records");
- sqlite3_clear_bindings(
- dbparameters_->statements_[DEL_ZONE_RECORDS]);
- if (sqlite3_bind_int(dbparameters_->statements_[DEL_ZONE_RECORDS],
- 1, zone_info.second) != SQLITE_OK) {
- isc_throw(DataSourceError,
- "failed to bind SQLite3 parameter: " <<
- sqlite3_errmsg(dbparameters_->db_));
- }
- delzone_exec.exec();
- } catch (const DataSourceError&) {
-
-
-
- StatementProcessor(*dbparameters_, ROLLBACK,
- "rollback an SQLite3 transaction").exec();
- throw;
- }
- }
- dbparameters_->updating_zone = true;
- dbparameters_->updated_zone_id = zone_info.second;
- return (zone_info);
- }
- void
- SQLite3Accessor::commitUpdateZone() {
- if (!dbparameters_->updating_zone) {
- isc_throw(DataSourceError, "committing zone update on SQLite3 "
- "data source without transaction");
- }
- StatementProcessor(*dbparameters_, COMMIT,
- "commit an SQLite3 transaction").exec();
- dbparameters_->updating_zone = false;
- dbparameters_->updated_zone_id = -1;
- }
- void
- SQLite3Accessor::rollbackUpdateZone() {
- if (!dbparameters_->updating_zone) {
- isc_throw(DataSourceError, "rolling back zone update on SQLite3 "
- "data source without transaction");
- }
- StatementProcessor(*dbparameters_, ROLLBACK,
- "rollback an SQLite3 transaction").exec();
- dbparameters_->updating_zone = false;
- dbparameters_->updated_zone_id = -1;
- }
- namespace {
- template <typename COLUMNS_TYPE>
- void
- doUpdate(SQLite3Parameters& dbparams, StatementID stmt_id,
- COLUMNS_TYPE update_params, const char* exec_desc)
- {
- sqlite3_stmt* const stmt = dbparams.statements_[stmt_id];
- StatementProcessor executer(dbparams, stmt_id, exec_desc);
- int param_id = 0;
- if (sqlite3_bind_int(stmt, ++param_id, dbparams.updated_zone_id)
- != SQLITE_OK) {
- isc_throw(DataSourceError, "failed to bind SQLite3 parameter: " <<
- sqlite3_errmsg(dbparams.db_));
- }
- const size_t column_count =
- sizeof(update_params) / sizeof(update_params[0]);
- for (int i = 0; i < column_count; ++i) {
-
-
- if (sqlite3_bind_text(stmt, ++param_id,
- update_params[i].empty() ? NULL :
- update_params[i].c_str(),
- -1, SQLITE_TRANSIENT) != SQLITE_OK) {
- isc_throw(DataSourceError, "failed to bind SQLite3 parameter: " <<
- sqlite3_errmsg(dbparams.db_));
- }
- }
- executer.exec();
- }
- }
- void
- SQLite3Accessor::addRecordToZone(const string (&columns)[ADD_COLUMN_COUNT]) {
- if (!dbparameters_->updating_zone) {
- isc_throw(DataSourceError, "adding record to SQLite3 "
- "data source without transaction");
- }
- doUpdate<const string (&)[DatabaseAccessor::ADD_COLUMN_COUNT]>(
- *dbparameters_, ADD_RECORD, columns, "add record to zone");
- }
- void
- SQLite3Accessor::deleteRecordInZone(const string (¶ms)[DEL_PARAM_COUNT]) {
- if (!dbparameters_->updating_zone) {
- isc_throw(DataSourceError, "deleting record in SQLite3 "
- "data source without transaction");
- }
- doUpdate<const string (&)[DatabaseAccessor::DEL_PARAM_COUNT]>(
- *dbparameters_, DEL_RECORD, params, "delete record from zone");
- }
- std::string
- SQLite3Accessor::findPreviousName(int zone_id, const std::string& rname)
- const
- {
- sqlite3_reset(dbparameters_->statements_[FIND_PREVIOUS]);
- sqlite3_clear_bindings(dbparameters_->statements_[FIND_PREVIOUS]);
- if (sqlite3_bind_int(dbparameters_->statements_[FIND_PREVIOUS], 1,
- zone_id) != SQLITE_OK) {
- isc_throw(SQLite3Error, "Could not bind zone ID " << zone_id <<
- " to SQL statement (find previous): " <<
- sqlite3_errmsg(dbparameters_->db_));
- }
- if (sqlite3_bind_text(dbparameters_->statements_[FIND_PREVIOUS], 2,
- rname.c_str(), -1, SQLITE_STATIC) != SQLITE_OK) {
- isc_throw(SQLite3Error, "Could not bind name " << rname <<
- " to SQL statement (find previous): " <<
- sqlite3_errmsg(dbparameters_->db_));
- }
- std::string result;
- const int rc = sqlite3_step(dbparameters_->statements_[FIND_PREVIOUS]);
- if (rc == SQLITE_ROW) {
-
- result = convertToPlainChar(sqlite3_column_text(dbparameters_->
- statements_[FIND_PREVIOUS], 0), dbparameters_->db_);
- }
- sqlite3_reset(dbparameters_->statements_[FIND_PREVIOUS]);
- if (rc == SQLITE_DONE) {
-
-
- isc_throw(isc::NotImplemented, "The zone doesn't support DNSSEC or "
- "query before apex");
- }
- if (rc != SQLITE_ROW && rc != SQLITE_DONE) {
-
- isc_throw(SQLite3Error, "Could not get data for previous name");
- }
- return (result);
- }
- namespace {
- void
- addError(ElementPtr errors, const std::string& error) {
- if (errors != ElementPtr() && errors->getType() == Element::list) {
- errors->add(Element::create(error));
- }
- }
- bool
- checkConfig(ConstElementPtr config, ElementPtr errors) {
-
- bool result = true;
- if (!config || config->getType() != Element::map) {
- addError(errors, "Base config for SQlite3 backend must be a map");
- result = false;
- } else {
- if (!config->contains(CONFIG_ITEM_DATABASE_FILE)) {
- addError(errors,
- "Config for SQlite3 backend does not contain a '"
- CONFIG_ITEM_DATABASE_FILE
- "' value");
- result = false;
- } else if (!config->get(CONFIG_ITEM_DATABASE_FILE) ||
- config->get(CONFIG_ITEM_DATABASE_FILE)->getType() !=
- Element::string) {
- addError(errors, "value of " CONFIG_ITEM_DATABASE_FILE
- " in SQLite3 backend is not a string");
- result = false;
- } else if (config->get(CONFIG_ITEM_DATABASE_FILE)->stringValue() ==
- "") {
- addError(errors, "value of " CONFIG_ITEM_DATABASE_FILE
- " in SQLite3 backend is empty");
- result = false;
- }
- }
- return (result);
- }
- }
- DataSourceClient *
- createInstance(isc::data::ConstElementPtr config, std::string& error) {
- ElementPtr errors(Element::createList());
- if (!checkConfig(config, errors)) {
- error = "Configuration error: " + errors->str();
- return (NULL);
- }
- std::string dbfile = config->get(CONFIG_ITEM_DATABASE_FILE)->stringValue();
- try {
- boost::shared_ptr<DatabaseAccessor> sqlite3_accessor(
- new SQLite3Accessor(dbfile, "IN"));
- return (new DatabaseClient(isc::dns::RRClass::IN(), sqlite3_accessor));
- } catch (const std::exception& exc) {
- error = std::string("Error creating sqlite3 datasource: ") + exc.what();
- return (NULL);
- } catch (...) {
- error = std::string("Error creating sqlite3 datasource, "
- "unknown exception");
- return (NULL);
- }
- }
- void destroyInstance(DataSourceClient* instance) {
- delete instance;
- }
- }
- }
|