latest revision of the mongodb backend

git-svn-id: svn://svn.powerdns.com/pdns/trunk/pdns@2203 d19b8d6e-7fed-0310-83ef-9ca221ded41b

diff --git a/modules/mongodbbackend/dnssec.cc b/modules/mongodbbackend/dnssec.cc
index 46e20b7c3ce45d50fbfb20e55bd14d8f2724ef42..eca546ffe8b9c5ca62a0e7a3483cf93205a1d328 100644 (file)
--- a/modules/mongodbbackend/dnssec.cc
+++ b/modules/mongodbbackend/dnssec.cc
@@ -281,9 +281,11 @@ bool MONGODBBackend::removeDomainKey(const string& name, unsigned int id) {
     }
 
     m_db.update(collection_cryptokeys, mongo_q, update );
+    
+    string m_error = m_db.getLastError();
 
-    if(logging_cerr) 
-       cerr << backend_name << "(removeDomainKey) getLastError: "<< m_db.getLastError()<< endl;
+    if(logging_cerr && !m_error.empty())
+       cerr << backend_name << "(removeDomainKey) getLastError: "<< m_error << endl;
     
     return true; //?? how do we know that ??
 }

diff --git a/modules/mongodbbackend/minimal.cc b/modules/mongodbbackend/minimal.cc
index 9ff8b4eba4bd4f68db7f0fc144632356f4b359a1..333a6c459d10ad89857f3378101cb84dcd9f29cc 100644 (file)
--- a/modules/mongodbbackend/minimal.cc
+++ b/modules/mongodbbackend/minimal.cc
@@ -65,28 +65,67 @@ MONGODBBackend::MONGODBBackend(const string &suffix) {
        if (checkindex) {
            L<<Logger::Error << backend_name << "(Re)creating index... " << endl;
 
+
            m_db.ensureIndex(collection_domains , BSON( "domain_id" << 1), true, "domain_id", true); //, true);
+           L<<Logger::Error << backend_name << "Index: domains: 'domain_id' done." << endl;
+
            m_db.ensureIndex(collection_domains , BSON( "name" << 1), true, "name", true); //, true);
+           L<<Logger::Error << backend_name << "Index: domains: 'name' done." << endl;
+
            m_db.ensureIndex(collection_domains , BSON( "type" << 1), false, "type", true); //, true);
-           m_db.ensureIndex(collection_domains , BSON( "account" << 1), false, "type", true); //, true);
+           L<<Logger::Error << backend_name << "Index: domains: 'type' done." << endl;
+
+           m_db.ensureIndex(collection_domains , BSON( "account" << 1), false, "account", true); //, true);
+           L<<Logger::Error << backend_name << "Index: domains: 'account' done." << endl;
+
 
            m_db.ensureIndex(collection_records, BSON( "domain_id" << 1), false, "domain_id", true); //, true);
+           L<<Logger::Error << backend_name << "Index: records: 'domain_id' done." << endl;
+           
            m_db.ensureIndex(collection_records, BSON( "name" << 1), false, "name", true); //, true);
+           L<<Logger::Error << backend_name << "Index: records: 'name' done." << endl;
+
            m_db.ensureIndex(collection_records, BSON( "name" << 1 << "type" << 1), true, "name_type", true); //, true);
+           L<<Logger::Error << backend_name << "Index: records: 'name_type' done." << endl;
+
            m_db.ensureIndex(collection_records, BSON( "domain_id" << 1 << "auth" << 1 << "ordername" << -1), false, "domainid_auth_ordername_desc", true); //, true);
+           L<<Logger::Error << backend_name << "Index: records: 'domainid_auth_ordername_desc' done." << endl;
+
            m_db.ensureIndex(collection_records, BSON( "domain_id" << 1 << "auth" << 1 << "ordername" << 1), false, "domainid_auth_ordername_asc", true); //, true);
+           L<<Logger::Error << backend_name << "Index: records: 'domainid_auth_ordername_asc' done." << endl;
+
            m_db.ensureIndex(collection_records, BSON( "domain_id" << 1 << "name" << 1 ), false, "domainid_name", true); //, true);
+           L<<Logger::Error << backend_name << "Index: records: 'domainid_name' done." << endl;
+
 
            m_db.ensureIndex(collection_domainmetadata, BSON( "name" << 1 ), true, "name", true); //, true);
+           L<<Logger::Error << backend_name << "Index: domainmetadata: 'name' done." << endl;
+
            m_db.ensureIndex(collection_domainmetadata, BSON( "name" << 1 << "content.kind" << 1), true, "name_kind", true); //, true);
+           L<<Logger::Error << backend_name << "Index: domainmetadata: 'name_kind' done." << endl;
+
 
            m_db.ensureIndex(collection_cryptokeys, BSON( "domain_id" << 1 ), true, "domain_id", true); //, true);
+           L<<Logger::Error << backend_name << "Index: cryptokeys: 'domain_id' done." << endl;
+
            m_db.ensureIndex(collection_cryptokeys, BSON( "name" << 1 ), true, "name", true); //, true);
+           L<<Logger::Error << backend_name << "Index: cryptokeys: 'name'  done." << endl;
+
            m_db.ensureIndex(collection_cryptokeys, BSON( "name" << 1 << "domain_id" << 1), true, "name_domainid", true); //, true);
+           L<<Logger::Error << backend_name << "Index: cryptokeys: 'name_domainid'  done." << endl;
+
            m_db.ensureIndex(collection_cryptokeys, BSON( "domain_id" << 1 << "content.id" << 1), true, "domainid_id", true); //, true);
+           L<<Logger::Error << backend_name << "Index: cryptokeys: 'domainid_id'  done." << endl;
+
            m_db.ensureIndex(collection_cryptokeys, BSON( "name" << 1 << "content.id" << 1), true, "name_id", true); //, true);
+           L<<Logger::Error << backend_name << "Index: cryptokeys: 'name_id'  done." << endl;
+
 
            m_db.ensureIndex(collection_tsigkeys, BSON( "name" << 1 << "content.algorithm" << 1), true, "name_algo", true); //, true);
+           L<<Logger::Error << backend_name << "Index: tsigkeys: 'name_algo' done." << endl;
+
+
+           L<<Logger::Error << backend_name << "(Re)creating index... DONE!" << endl;
 
        }
     }
@@ -101,7 +140,7 @@ MONGODBBackend::MONGODBBackend(const string &suffix) {
 }
   
 MONGODBBackend::~MONGODBBackend() {
-//     delete m_db;
+//    delete m_db;
     L<<Logger::Info<<backend_name<<"Disconnected!" << endl;
 }
 
@@ -127,6 +166,7 @@ void MONGODBBackend::lookup(const QType &qtype, const string &qname, DNSPacket *
     q_name = qname;
     
     mongo_query = q_type == "ANY" ? QUERY( "name" << toLower(qname) ) : QUERY( "name" << toLower(qname) << "type" << q_type);
+    mongo_query.hint(q_type == "ANY" ? BSON("name" << 1) : BSON("name" << 1 << "type" << 1));
        
     elements = false;
     default_ttl = 0;
@@ -135,7 +175,7 @@ void MONGODBBackend::lookup(const QType &qtype, const string &qname, DNSPacket *
        L<<Logger::Info<< backend_name <<"(lookup) Query: "<< mongo_query.toString() << endl;
        
     cursor = m_db.query(collection_records, mongo_query);
-       
+    
 }
 
 bool MONGODBBackend::content(DNSResourceRecord* rr) {
@@ -252,8 +292,8 @@ again:
                }
            }
        
-//             if (contents)
-//                     delete contents;
+//         if (contents)
+//             delete []contents;
 
            contents = new mongo::BSONObjIterator(mongo_record.getObjectField("content"));
                    
@@ -264,7 +304,7 @@ again:
            goto again;
        }
     } 
-       
+
     return !rr.content.empty() ;
 }
 
@@ -272,6 +312,6 @@ bool MONGODBBackend::getSOA(const string &name, SOAData &soadata, DNSPacket *p)
     //please see getDomainInfo in slave.cc for this function.
     
     DomainInfo DI;
-
+    
     return getDomainInfo(name, DI, &soadata);
 }

diff --git a/modules/mongodbbackend/private.cc b/modules/mongodbbackend/private.cc
index 78e1caf852b538f0e935c48aa54c814f5e428c58..f50e3fc0e8ad5292d07d670dea43e1cbfdc051ad 100644 (file)
--- a/modules/mongodbbackend/private.cc
+++ b/modules/mongodbbackend/private.cc
@@ -28,6 +28,7 @@ bool MONGODBBackend::checkDomainInfo(const string *domain, mongo::BSONObj *mongo
            
        di->id = mongo_r->getIntField("domain_id");
        di->last_check = mongo_r->getIntField("last_check");
+       di->notified_serial = mongo_r->getIntField("notified_serial");
 
        if (soadata == NULL) 
            for( bson::bo::iterator i(mongo_r->getObjectField("masters")); i.more(); ) {