Testes de banco de dados

data/collection_test.json

@@ -0,0 +1 @@
+[{"_id":"37240c0cb8ab4a7dacd91acaca5fdc5e","nome":"Adriano Waltrick"}]

services/diskdb.js

@@ -0,0 +1,16 @@
+// var npm_diskdb = require('diskdb');
+
+function getDbConexoes(npm_diskdb)
+{
+    var db = npm_diskdb.connect(
+        './data/',
+        ['conexoes']
+    );
+
+    return db.conexoes;
+}
+
+
+module.exports = {
+    getDbConexoesApp: getDbConexoes
+};

services/mysql.js

@@ -0,0 +1,61 @@
+function execQuery(
+    objConexao,
+    ds_query,
+    fnCallBackResult
+) {
+    return new Promise(
+        function (resolve, reject) {
+            objConexao.connect();
+
+            objConexao.query(
+                ds_query,
+                function (error, arrColunas) {
+                    objConexao.end();
+
+                    if (error){
+                        reject(error);
+                        return;
+                    }
+
+                    resolve(
+                        fnCallBackResult(
+                            arrColunas,
+                            resolve,
+                            reject
+                        )
+                    );
+                }
+            );
+        }
+    );
+}
+
+function getDatabases(objConexao) {
+    var ds_query = 'SHOW DATABASES';
+
+    var fnCallBack = function(
+        arrValores,
+        resolve,
+        reject
+    ) {
+        var arrDatabases  = arrValores.map(
+            function(objColuna) {
+                return {
+                    ds_nome : objColuna.Database
+                };
+            }
+        );
+
+        resolve(arrDatabases);
+    }
+
+    return execQuery(
+        objConexao,
+        ds_query,
+        fnCallBack
+    );
+}
+
+module.exports = {
+    getDatabases: getDatabases
+};

test/diskdb_test.js

@@ -0,0 +1,60 @@
+var assert = require('assert');
+var npm_db = require('diskdb');
+var chai = require('chai');
+var expect = chai.expect;
+
+
+
+describe(
+    'Teste de diskdb',
+    function() {
+        it(
+            'Remove - save - count',
+            function (done) {
+                var db = npm_db.connect(
+                    './data/',
+                    ['collection_test']
+                );
+
+                db.collection_test.remove();
+                db = null;
+
+                db = npm_db.connect(
+                    './data/',
+                    ['collection_test']
+                );
+
+                var objRegistro = {
+                    _id : '0ce47983623f4fb096ab3303d7bb6de7',
+                    nome : 'Adriano Waltrick'
+                };
+
+                db.collection_test
+                    .save(objRegistro);
+
+                var arrValor = db.collection_test.find();
+                expect(arrValor.length).to.equal(1);
+                expect(db.collection_test.count()).to.equal(1);
+
+
+                done();
+            }
+        );
+
+        it(
+            'find',
+            function (done) {
+                var db = npm_db.connect(
+                    './data/',
+                    ['collection_test']
+                );
+
+                var arrValor = db.collection_test.find();
+                expect(arrValor.length).to.equal(1);
+                expect(db.collection_test.count()).to.equal(1);
+
+                done();
+            }
+        );
+    }
+);

test/mysql_test.js

@@ -0,0 +1,51 @@
+var assert = require('assert');
+var npm_mysql = require('mysql');
+
+// app
+const objMysql = require('../services/mysql.js');
+
+describe(
+    'Teste Servico Mysql',
+    function() {
+        describe(
+            '#getDatabases(objConexao)',
+            function() {
+                it(
+                    'Total de databases',
+                    function(done) {
+                        const objConnectionBaseA = npm_mysql.createConnection({
+                            host     : "localhost",
+                            user     : "backup",
+                            password : "UniSeguro",
+                            database : "adriano"
+                        });
+
+                        const nr_qtd_database = 18;
+
+                        objMysql.getDatabases(
+                            objConnectionBaseA
+                        ).then(
+                            function(arrResultadoA) {
+                                var a = assert.equal(
+                                    arrResultadoA.length,
+                                    nr_qtd_database
+                                );
+
+                                var b = assert.equal(
+                                    arrResultadoA[0].ds_nome,
+                                    'information_schema'
+                                );
+
+                                done();
+                            }
+                        ).catch(
+                            function (objError) {
+                                console.log(objError);
+                            }
+                        );
+                    }
+                );
+            }
+        );
+    }
+);