Las características de N1QL están llegando a más y más SDKs- ahora incluyendo Ruby. Me gustaría dar una rápida introducción de cómo funcionan las consultas estructuradas en Ruby. Por el momento la librería no provee un ODM o alguna otra abstracción de alto nivel encima de ella, pero casi todo es posible de otra manera.
Se ha añadido soporte experimental para N1QL en reciente versión menor 1.3.12 aunque es posible que la API cambie en la versión final. En los siguientes ejemplos le mostraré cómo trabajar con ella utilizando nuevo conjunto de datos sobre viajesque se encuentra en el 4.0 avance para desarrolladores. En este blog, estoy asumiendo aquí que usted ha instalado la versión más reciente del cliente ruby (si no es así, por favor ejecute "gem install -v 1.3.12") y tener un Couchbase Server local con el servicio de consulta activado.
En primer lugar, vamos a establecer una conexión con el cubo:
|
1 |
cb = Couchbase.conecte(cubo: 'travel-sample') |
El punto de entrada para las consultas N1QL es Couchbase::Bucket#query que acepta una cadena en N1QL y devuelve un hash con :rows y :meta donde se entrega la respuesta del servidor. Si hay un problema, la biblioteca levantará Couchbase::Error::Consulta con metadatos adjuntos para analizar el error.
Por ejemplo, vamos a crear un índice primario para todo el conjunto de datos:
|
1 |
cb.consulta("CREATE PRIMARY INDEX on `viaje-muestra`") |
Con el índice primario definido podemos obtener los documentos por sus claves:
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 |
cb.consulta('SELECT * FROM `travel-sample` USE KEYS ["airline_24"]') # => {:filas=> # [{"viaje-muestra"=> # {"indicativo"=>"AMERICANO", # "country"=>"Estados Unidos", # "iata"=>"AA", # "icao"=>"AAL", # "id"=>24, # "name"=>"American Airlines", # "type"=>"airline"}}], # :meta=> # {"requestID"=>"7cc10c30-ecb7-4e65-b582-fe9852e85d5b", # "firma"=>{"*"=>"*"}, # "resultados"=>[], # "status"=>"éxito", # "métricas"=> # {"elapsedTime"=>"8.308061ms", # "executionTime"=>"8.206911ms", # "resultCount"=>1, # "resultSize"=>306}}} |
Para simplificar los ejemplos, podemos utilizar la siguiente función para despojar :meta y extraer sólo los valores.
|
1 2 3 |
def tira(doc) doc[:filas] fin |
Vamos a responder a algunas preguntas sobre este cubo de muestra. Como recordarás, los datos de cerveza de muestra anteriores contenían unos 7.000 documentos:
|
1 2 |
tira cb.consulta('SELECT COUNT(*) AS total FROM `viajes-muestra`') # => [{"total"=>31621}] |
Es una gran caja de arena para nuestros experimentos. ¿Qué tipo de documentos contiene?
|
1 2 3 4 5 |
tira cb.consulta('SELECT tipo, COUNT(*) COMO total FROM `viaje-muestra` GROUP BY tipo') # => [{"total"=>1969, "tipo"=>"aeropuerto"}, # {"total"=>5389, "type"=>"landmark"}, # {"total"=>187, "type"=>"airline"}, # {"total"=>24076, "tipo"=>"ruta"}] |
Como tarea para casa, puedes explorar más a fondo la estructura de la base de datos de ejemplo. De momento, respondamos a algunas preguntas más prácticas. ¿Qué rutas están disponibles para alguien en Los Ángeles que quiere ver la Torre Eiffel en París? Una aplicación sencilla podría ser la siguiente (suponiendo que sepa lo que significan LAX y CDG).
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 |
requiere 'date' rutas = tira cb.consulta(' SELECCIONE aerolínea.nombre, ruta.equipo, ruta.horario DESDE `viaje-muestra` ruta ÚNASE A `viaje-muestra` aerolínea EN llaves ruta.airlineid DONDE ruta.fuenteaeropuerto = "LAX" Y ruta.destinoaeropuerto = "CDG" ') rutas.cada do |ruta| pone("--------------------------") pone("#{route['name']} (#{route['equipment']})") pone("--------------------------") ruta['horario'].each do |vuelo| día = Fecha::ABBR_DAYNAMES[vuelo['day']] pone("#{flight['flight']}: #{flight['utc']}, #{day}") fin fin |
Si ejecutas este código, obtendrás una tabla horaria con un buen formato de todas las rutas para ver la famosa torre, como se muestra a continuación.
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 |
-------------------------- Delta Aire Líneas (388 772) -------------------------- DL024: 03:23:00, Sol DL856: 04:38:00, Sol DL124: 06:01:00, Sol DL249: 06:00:00, Sol DL142: 10:00:00, Lun DL757: 10:44:00, Mar ... -------------------------- Aire Tahití Nui (343) -------------------------- TN070: 06:03:00, Sol TN040: 08:39:00, Lun TN832: 11:42:00, Mar TN752: 08:32:00, Mar TN519: 23:33:00, Mar TN278: 05:27:00, Mar TN325: 18:07:00, Miércoles ... |
Esto es todo por el momento, por favor, déjanos tus comentarios sobre la nueva consulta. En particular, dinos qué tipo de soporte para Ruby te gustaría ver.
se ve bien, mirando hacia adelante para una muestra node.js :)