florian/ExpressJS-Mongo
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

WIP

Browse Source
This commit is contained in:
Pierre THIERRY
2020-09-06 12:20:22 +02:00
parent 14da8bf0f1
commit d4cc887bf5
2 changed files with 22 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
src/js/app.js
View File

@@ -8,11 +8,22 @@ const port = 3000;
const mongoClient = new MongoClient(); const mongoClient = new MongoClient();
app.get('/test', (request, response) => { app.get('/test', (request, response) => {
mongoClient.insert('test', {creationDate: new Date()}, () => { mongoClient.find('test', {}, results => {
mongoClient.find('test', {}, results => { response.json(results);
console.log(results); });
response.send(JSON.stringify(results)); });
});
app.get('/test2', (request, response) => {
// mongoClient.insert('test', {address: 'localhost'}, (result) => {
// response.json(result);
// });
// mongoClient.update('test', {_id: '5f54b1c0f4dca82b7ad825bc', address: '127.0.0.1', updated: new Date()}, (result) => {
// response.json(result);
// });
mongoClient.delete('test', '5f54b6c52d9355311a4e68a0', () => {
response.status(200).send('Deleted');
}); });
}); });

12
src/js/mongoClient.js
View File

@@ -1,4 +1,5 @@
const mongodb = require('mongodb'); const mongodb = require('mongodb');
const ObjectID = require('mongodb').ObjectID;
const assert = require('assert'); const assert = require('assert');
const mongoConfig = { const mongoConfig = {
@@ -21,7 +22,6 @@ class MongoClient {
this.db.collection(collectionName).find(query).toArray() this.db.collection(collectionName).find(query).toArray()
.then(results => { .then(results => {
console.log(`Entities ${collectionName} founded.`); console.log(`Entities ${collectionName} founded.`);
console.log(results);
callback(results); callback(results);
}) })
.catch(error => console.error(error)); .catch(error => console.error(error));
@@ -36,19 +36,19 @@ class MongoClient {
}); });
} }
update(collectionName, entity, query, callback) { update(collectionName, entity, callback) {
this.db.collection(collectionName).update(query, entity, (error, result) => { this.db.collection(collectionName).save(entity, (error) => {
assert.equal(null, error, `Unable to update ${collectionName} entity: ${error}.`); assert.equal(null, error, `Unable to update ${collectionName} entity: ${error}.`);
console.log(`Entity ${collectionName} updated.`); console.log(`Entity ${collectionName} updated.`);
callback(result); callback();
}); });
} }
delete(collectionName, entityId, callback) { delete(collectionName, entityId, callback) {
this.db.collection(collectionName).deleteOne({id: entityId}, (error, result) => { this.db.collection(collectionName).deleteOne({id: new ObjectID(entityId)}, (error) => {
assert.equal(null, error, `Unable to delete ${collectionName} entity with id ${entityId}: ${error}.`); assert.equal(null, error, `Unable to delete ${collectionName} entity with id ${entityId}: ${error}.`);
console.log(`Entity ${collectionName} with id ${entityId} deleted.`); console.log(`Entity ${collectionName} with id ${entityId} deleted.`);
callback(result); callback();
}); });
} }
} }