Accediendo a nuestra base de datos Rethinkdb desde Node.js

Clase 9 de 61 • Curso Profesional de Node.js y JavaScript 2016

Resumen

Acceder a nuestra base de datos de muy fácil gracias a la API de RethinkDB. Lo primero que necesitamos estructurar son las opciones de host, port y nombre de la base de datos.

Después, la conexión puedes hacerla con callback o con promesas, esta segunda opción es la que recomendamos.

Para mejorar el flujo-control de nuestra aplicación, usaremos co, mejorando la sintaxis y teniendo en cuenta yield para pausar la ejecución hasta que se resuelva la promesa.

Sobreescribimos la clase Promise que tiene por defecto ECMAScript por una librería llamada bluebird, permitiendo conectarnos como callback o como promesa (Interfaz híbrida) a nuestra clase.

Gilberto Francisco Naranjo Valles

student•

Tengo una pregunta en esta parte… tengo el código igual que el profesor. pero al momento de ir a la consola y escribir db. para ver la clase… la consola me retorna un " … " y cuando escribo el db.connect me tira el siguiente error “db.db.connect is not a function, on repl:3:4” espero su pronta respuesta para poder continuar… Muchas gracias de antemano…

Kath Sánchez

teacher•

¿Nos compartes tu código para revisarlo?

Gilberto Francisco Naranjo Valles

student•

claro que si.

'use strict'

const co = require('co')
const r = require('rethinkdb')
const Promise = require('bluebird')

const defaults = {
  host: 'localhost',
  port: 28015,
  db: 'Taste Wonerful'
}

class Db {
  constructor (options) {
    options = options | {}
    this.host = options.host | defaults.host
    this.port = options.port | defaults.port
    this.db = options.db | defaults.db
  }

  connect (callback) {
    this.connection = r.connect({
      host: this.host,
      port: this.port
    })

    let db = this.db
    let connection = this.connection

    let setup = co.wrap(function * () {
      let conn = yield connection

      let dbList = yield r.dbList().run(conn)
      if (dbList.indexOf(db) === -1) {
        yield r.dbCreate(db).run(conn)
      }

      let dbTables = yield r.db(db).tableList().run(conn)
      if (dbTables.indexOf('images') === -1) {
        yield r.db(db).tableCreate('images').run(conn)
      }

      if (dbTables.indexOf('users') === -1) {
        yield r.db(db).tableCreate('users').run(conn)
      }

      return conn
    })

    return Promise.resolve(setup()).asCallback(callback)
  }
}

module.exports = Db

Álvaro René Sánchez Serrano

student•

¿entonces co.wrap() es como si fuera async y yield es await?

José Luis Ruiz Moreno

student•

Te recomiendo leer este articulo:

Explica un poco esas cosas y más

Armando Alamilla Cuellar

student•

Cuando utilizo

db.connect (function (err, c) {console.log(c)})

Todo bien
pero cuando pongo

db.connect().then((c) => console.log(c))

aparece el siguiente error:

Unhandled rejection ReqlDriverError: Could not connect to localhost:28015.
connect ECONNREFUSED 127.0.0.1:28015
at ReqlDriverError.ReqlError [as constructor] (C:\Users\Armando\Desktop\Carpetas\Armando Alamilla Cuéllar\javascript 2016\AyA-gram-db\node_modules\rethinkdb\errors.js:23:13)
at new ReqlDriverError (C:\Users\Armando\Desktop\Carpetas\Armando Alamilla Cuéllar\javascript 2016\AyA-gram-db\node_modules\rethinkdb\errors.js:68:50)
at TcpConnection.<anonymous> (C:\Users\Armando\Desktop\Carpetas\Armando Alamilla Cuéllar\javascript 2016\AyA-gram-db\node_modules\rethinkdb\net.js:94:27)
at Object.onceWrapper (events.js:315:30)
at emitOne (events.js:116:13)
at TcpConnection.emit (events.js:211:7)
at Socket.<anonymous> (C:\Users\Armando\Desktop\Carpetas\Armando Alamilla Cuéllar\javascript 2016\AyA-gram-db\node_modules\rethinkdb\net.js:705:22)
at emitOne (events.js:121:20)
at Socket.emit (events.js:211:7)
at emitErrorNT (internal/streams/destroy.js:64:8)
at _combinedTickCallback (internal/process/next_tick.js:138:11)
at process._tickDomainCallback (internal/process/next_tick.js:218:9)

Diego Forero

Team Platzi•

Puedes compartir el modulo Db.js para verificar que no tengas algún error al implementar la parte de las promesas, puede ser que no este llegando los parámetros ya que dice que no se puede conectar al servidor en el puerto 28015.

Armando Alamilla Cuellar

student•

'use strict'

const co = require('co')
const r = require('rethinkdb')
const Promise = require('bluebird')

const defaults = {
	host: 'localhost',
	port: 28015,
	db: 'ayagram'
}

class Db {
	constructor (options) {
		options = options || {}
		this.host = options.host || defaults.host
		this.port = options.port || defaults.port
		this.db = options.db || defaults.db
	}

	connect (callback) {
		this.connection = r.connect({
			host: this.host,
			port: this.port
		})

		let db = this.db
		let connection = this.connection;

		let setup = co.wrap(function * () {
			let conn = yield connection

			let dbList = yield r.dbList().run(conn)
			if (dbList.indexOff(db) === -1) {
				yield r.dbCreate(db).run(conn)
			}

			let dbTables = yield r.db(db).tableList().run(conn)
			if (dbTables.indexOff('images') === -1) {
				yield r.db(db).tableCreate('images').run(conn)
			}

			if (dbTables.indexOff('users') === -1) {
				yield r.db(db).tableCreate('users').run(conn)
			}

			return conn
		})

		return Promise.resolve(setup()).asCallback(callback)
	}
}

module.exports = Db

no se si tenga algo que ver pero cambié el db por
db: 'ayagram’
como alternativa a platzigram e instagram

Juan Diego Silva Garcia

student•

Alguien le pasó esto en Windows ? que se quede en puntos suspensivos …

> var Db = require('./lib/db')
undefined
> var db = new Db()
undefined
> db.
...

Sergio Daniel Xalambrí

student•

Esta esperando que coloques una propiedad o un método.

Juan Diego Silva Garcia

student•

@sergiodxa gracias por tu respuesta pero lo hice igual que el profesor Julian, entonces que método o propiedad debería colocar?

Eduardo Uribe González Gonzàlez

student•

Me aparece este en el REPL de Node al hacer la conexión, si alguien me puede ayudar.

var Db = require('./lib/db')

/home/Documentos/JS/platzigramParte2/platzigramdb/lib/db.js:28

  let db = this.db

^^

SyntaxError: Unexpected identifier

    at exports.runInThisContext (vm.js:53:16)

    at Module._compile (module.js:373:25)

    at Object.Module._extensions..js (module.js:416:10)

    at Module.load (module.js:343:32)

    at Function.Module._load (module.js:300:12)

    at Module.require (module.js:353:17)

    at require (internal/module.js:12:17)

    at repl:1:10

    at REPLServer.defaultEval (repl.js:262:27)

    at bound (domain.js:287:14)

Sacha Lifszyc

teacher•

qué versión de node tienes?

Daniel Alexander Vinet

student•

Me salio este error y tengo todo el código igual

> var db = new Db()
TypeError: Db is not a constructor
    at repl:1:10
    at sigintHandlersWrap (vm.js:22:35)
    at sigintHandlersWrap (vm.js:73:12)
    at ContextifyScript.Script.runInThisContext (vm.js:21:12)
    at REPLServer.defaultEval (repl.js:346:29)
    at bound (domain.js:280:14)
    at REPLServer.runBound [as eval] (domain.js:293:12)
    at REPLServer.<anonymous> (repl.js:545:10)
    at emitOne (events.js:101:20)
    at REPLServer.emit (events.js:188:7)
    at REPLServer.Interface._onLine (readline.js:230:10)
    at REPLServer.Interface._line (readline.js:576:8)
    at REPLServer.Interface._ttyWrite (readline.js:853:14)
    at REPLServer.self._ttyWrite (repl.js:618:7)
    at ReadStream.onkeypress (readline.js:117:10)
    at emitTwo (events.js:106:13)
    at ReadStream.emit (events.js:191:7)
    at emitKeys (internal/readline.js:389:14)
    at next (native)
    at ReadStream.onData (readline.js:963:36)
    at emitOne (events.js:96:13)
    at ReadStream.emit (events.js:188:7)```

Alguien sabe que significa?

Daniel Alexander Vinet

student•

Ya lo resolvi, solo tenia que abrir el programa de rethinkdb

william ricardo ariza vélez

student•

UUuu que paso con TDD ? en este caso por que no se uso ?

Yeison Daza

student•

Existen casos donde es complejo seguir TDD :s

Luis Jhohan Venegas Tobar

student•

Implemente mi clase db pero al ejecutarla desde los test pasa la prueba pero no me crea datos en la rethinkdb, aunque si la ejecuto desde node funciona correctamente, alguien me puede ayudar

gracias

Kath Sánchez

teacher•

Puede ser que en tu prueba estás creando la BD de prueba y luego la borras.

Carlos Valdivia L.

student•

Instale rethinkdb en 45.55.146.89:8080 , en digital ocean ,y al acceder me da el mensaje:

No se puede acceder a 45.55.146.89 ...rechazó la conección

Kath Sánchez

teacher•

Debes cambiar el listen del servidor de BD a 0.0.0.0

Opciones bind: a bind: all

Carlos Valdivia L.

student•

Como se llama el archivo de configuración que debo modificar y donde se encuentra…(tengo un archivo /etc/rethinkdb/default.conf.sample) …muchas gracias…

Stefany Zapata Naranjo

student•

En donde puedo encontrar la documentación de bluebird y no me queda claro el tema de promesas??

Yeison Daza

student•

http://bluebirdjs.com/docs/getting-started.html

Nicolas Alejandro Herrera

student•

no me quedo claro lo de las promesas, a que se refiere con con resolver la promesa setup???

Yeison Daza

student•

De pronto este video te ayude a entender un poco mejor

https://www.youtube.com/watch?v=tSc9nQ6gZQ4

Jonathan Andres Diaz Moreno

student•

utilizo ubuntu 16.04 cuando intento instalar co me dice que no es compatible con mi sistema operativo que puedo hacer

Rafael Villarreal

student•

Por qué no están publicando el link al repositorio de los archivos del proyecto?

Arturo Muñoz

student•

tengo un error con la variable connection me dice que es undefined. lo que me llama la atención es que en el video se llama a this.connection y en ningun momento he visto que se ha declarado como atributo de la clase

Marco de los Santos

student•

¿Donde puedo descargar el código de esta parte para corroborar mis errores?

Sacha Lifszyc

teacher•

Los archivos fueron agregados en este video. Recuerda que puedes consultar todo el código en el repositorio de Github del proyecto.

Dawin Ossa

student•

El siguiente código no me devuelve el response esperado(de hecho no devuelve nada) pero si registra:

      let resultSave = r.db(db).table('posts').insert({
        id: 1,
        title: 'Lorem ipsum',
        content: 'Dolor sit amet'
      }).run(conn)
   
      resultSave
      .then(result => console.log('result', result))
      .error(error => console.log('Error', error))

Juan Francisco Esperanza Contreras

student•

Se pued eimplementar babel en el cakend con nodejs

Sergio Daniel Xalambrí

student•

cackend? te referís al backend? sí se puede, tenés varias opciones, usar babel-node para correr Node usando Babel (bueno para desarrollo, malo para producción), usar Babel para tomar tus archivos originales (source code) y generar los finales parsedos por Babel y luego correrlos con Node normal (bueno para producción).

También podrías usar herramientas como Webpack junto a Babel para generar un único archivo con todo el código de tu servidor de Node.js.

Juan Francisco Esperanza Contreras

student•

Disculpa fue un typo, muchas gracias por al respuesta sue muy clara la respuesta, pero que es màs recomendable como buena practica de programaciòn usar el JavaScript que utiliza NodeJs o implementar ES2015 y procesarlo con babel

Armando Alamilla Cuellar

student•

Cuando utilizo

db.connect (function (err, c) {console.log(c)})

Todo bien
pero cuando pongo

db.connect().then((c) =>console.log(c))

aparece el siguiente error:

Unhandled rejection ReqlDriverError: Could not connect to localhost:28015.
connect ECONNREFUSED 127.0.0.1:28015
at ReqlDriverError.ReqlError [as constructor] (C:\Users\Armando\Desktop\Carpetas\Armando Alamilla Cuéllar\javascript 2016\AyA-gram-db\node_modules\rethinkdb\errors.js:23:13)
at new ReqlDriverError (C:\Users\Armando\Desktop\Carpetas\Armando Alamilla Cuéllar\javascript 2016\AyA-gram-db\node_modules\rethinkdb\errors.js:68:50)
at TcpConnection.<anonymous> (C:\Users\Armando\Desktop\Carpetas\Armando Alamilla Cuéllar\javascript 2016\AyA-gram-db\node_modules\rethinkdb\net.js:94:27)
at Object.onceWrapper (events.js:315:30)
at emitOne (events.js:116:13)
at TcpConnection.emit (events.js:211:7)
at Socket.<anonymous> (C:\Users\Armando\Desktop\Carpetas\Armando Alamilla Cuéllar\javascript 2016\AyA-gram-db\node_modules\rethinkdb\net.js:705:22)
at emitOne (events.js:121:20)
at Socket.emit (events.js:211:7)
at emitErrorNT (internal/streams/destroy.js:64:8)
at _combinedTickCallback (internal/process/next_tick.js:138:11)
at process._tickDomainCallback (internal/process/next_tick.js:218:9)

este es mi código:

'use strict'

const co = require('co')
const r = require('rethinkdb')
const Promise = require('bluebird')

const defaults = {
	host: 'localhost',
	port: 28015,
	db: 'ayagram'
}

class Db {
	constructor (options) {
		options = options || {}
		this.host = options.host || defaults.host
		this.port = options.port || defaults.port
		this.db = options.db || defaults.db
	}

	connect (callback) {
		this.connection = r.connect({
			host: this.host,
			port: this.port
		})

		let db = this.db
		let connection = this.connection;

		let setup = co.wrap(function * () {
			let conn = yield connection

			let dbList = yield r.dbList().run(conn)
			if (dbList.indexOff(db) === -1) {
				yield r.dbCreate(db).run(conn)
			}

			let dbTables = yield r.db(db).tableList().run(conn)
			if (dbTables.indexOff('images') === -1) {
				yield r.db(db).tableCreate('images').run(conn)
			}

			if (dbTables.indexOff('users') === -1) {
				yield r.db(db).tableCreate('users').run(conn)
			}

			return conn
		})

		return Promise.resolve(setup()).asCallback(callback)
	}
}

module.exports = Db

erick blanco

student•

yield es una palabra reservada para obtener una promesa?

Jesus Africano

student•

Por lo que comprendi yield pertenece a co y es como que usaramos await de async/await, que en teoria pausa la ejecucion del codigo hasta que la promesa responde.

Sergio Daniel Xalambrí

student•

yield es un keyword que existe solo en las funciones generadoras creadas con function* y se usa para pausar el generador y devolver un valor, por ejemplo:

function* fibonacci() {  

  let anterior = 0, actual = 1;  

  while(true) {  

    let temp = anterior;  

    anterior = actual;  

    actual  += temp;  

    yield actual;  

  }  

}  

  

let fibo = fibonacci();  

  

for (let i = 0; i < 5; i++) {  

  console.log(fibo.next());  

}

En este caso el generador fibonacci al iniciarlo devuelve fibo que es una instancia de un objeto Iterator que cada vez que le pidamos un valor usando fibo.next() nos va a devolver el siguiente número de la serie de fibonacci, cada vez que se devuelve el valor el generador se va a detener y no va a continuar su ejecución hasta que se pida otro valor.

Accediendo a nuestra base de datos Rethinkdb desde Node.js

Crea el backend de tu aplicación

Introducción y arquitectura de nuestro proyecto

Cómo crear una cuenta de Amazon Web Services y configurar S3 ( Almacenamiento de Archivos )

Usando el SDK de Amazon Web Services

Cómo agregar Standard ( Linter ) a nuestro código en JavaScript

Testing en JavaScript usando AVA

Prueba unitaria para validar un array

Uso de expresiones regulares para nuestras pruebas unitarias

Módulo de base de datos con RethinkDB

Introduccion a RethinkDB

Accediendo a nuestra base de datos Rethinkdb desde Node.js

Creación de test para RethinkDB y almacenamiento de ruta de imágenes

Almacenamiento de rutas de imágenes en RethinkDB

Completando el test para nuestro objeto imagen

Creación de un fixture para test de petición de imágenes

Petición de de imagen desde base de datos

Consulta de todas las imágenes de nuestra base de datos

Buenas prácticas de creación de usuarios en Backend (Encriptación con Hash)

Petición de un usuario desde base de datos

Autenticación de usuario mediante password

Control de errores mediante excepciones (Try, Catch, Throws )

Consulta de imágenes en relación a nombre de usuario

Consulta de imágenes en relación a tag

Preparando nuestro módulo para microservicios

Módulo del API de nuestra aplicación

Introducción a los Microservicios

Creación de rutas para microservicios

Creación de nuestro endpoint GET /picture

Creción de nuestro endpoint POST /picture

Creción de nuestro endpoint POST /picture/:id/like

Creción de nuestro endpoint GET /picture/list

Creción de nuestro endpoint GET /picture/tag

Creación de nuestro endpoint POST /user

Creación de nuestro endpoint GET /user-name

Creación de Tokens para nuestro API usando JSON Web Tokens

Limitando nuestros request esperando recibir un Token

Test de autenticación de usuario

Módulo de Client de nuestra aplicación

Creación de nuestro cliente

Implementando el perfil de usuario

Carga de imágenes desde nuestro cliente

Cómo implementar autenticación de usuarios con Passport

Configurando un middleware en express

Estrategia de autenticación local (password / contraseña )

Consulta, altas de usuarios y manejos de errores en autenticación

Autenticación con Facebook

Creación de un token del API a partir de autenticación por Facebook

Manejo de sesiones de usuarios

Integración con nuestro Frontend

Consulta y alta de imagenes

Implementación de perfil de usuario

RealTime con Socket.io

Implementación de de Socket.io junto con RethinkDB

Escuchar un evento y mostrar los cambios en frontend

Lleva tu proyecto a producción

Introduccion a Vagrant

Creando nuestra primer maquina virtual con Vagrant

Introduccion a Ansible

Creando nuestro primer rol de ansible

Creando nuestro primer playbook para despliegue

Crear tareas para Platzigram dentro de Ansible

Crear tareas para el resto de los proyectos

Creación de servicios de upstart

Introducción a NGINX

Creación de rutas para nuestros microservicios

Llevando nuestro proyecto a Digital Ocean

Dominio y proyecto en producción

Terminaste este curso, tenemos buenas noticias, entra y entérate.