Kotlin, Camel y MyBatis

Introducción

Ya con nuestro servicio en forma de mock, podemos empezar a extenderlo un poco mas e incluir mas endpoints. En ese sentido agregaremos consultas a una base de datos, usando MySQL; no sera una tabla muy grande, pero servirá para ejemplificar el proceso. El mapeador de objetos java a SQL sera MyBatis, voy a hacer enojar a muchos tal vez, pero considero que JPA es de los frameworks mas obscuros del mundo Java :D, no se enojen; a mi no me gusta, no significa que no sea util para alguien.

Vamos a obtener los datos de la base para las operaciones que ya creamos, getAll y getByID, asimismo agregaremos una operación mas para insertar Preguntas en la base.

Prerequisitos

Ahora si tenemos mas pre-requisitos:

• MySQL instalado en donde sea pero que tengamos acceso a una base
• El conector jdbc-mysql en el repo local de maven
• El proyecto hasta el POST anterior

La Base de Datos

La base por ahora solo sera una tabla QUESTION, con la estructura siguiente:

 

Desarrollo

Dependencias

Vamos a necesitar las siguientes dependencias en nuestro archivo build.gradle:

• compile "org.apache.camel:camel-mybatis:$camel_version"
• compile "org.apache.camel:camel-jackson:$camel_version"
• compile group: 'com.fasterxml.jackson.core', name: 'jackson-databind', version: '2.9.3'
• compile group: 'com.fasterxml.jackson.jaxrs', name: 'jackson-jaxrs-json-provider', version: '2.9.3'
• compile 'mysql:mysql-connector-java:5.1.45'

Y vamos a remover la dependencia de Gson, esto es porque no encontré un json-provider para REST con Gson.

Cambiando el tipo de registro

Para continuar necesitamos actualizar el registro de Camel a que sea de tipo Jndi, de este modo podemos agregar fácilmente beans al contexto. En la carpeta src/main/resources creamos un archivo properties de nombre jndi.properties con el siguiente contenido:

 

Mapeo de MyBatis

Creamos una carpeta de nombre mybatis en la carpeta src/main/resources, dentro de esta carpeta creamos un archivo xml question con el siguiente contenido:

 

Nada del otro mundo, es solo el mapeador y las tres operaciones: getAllQuestions - SELECT, getQuestionById - SELECT y addQuestion- INSERT.
Lo que mas me gusta de esto es que los querys están claros, siempre sabemos que query se ejecutara para cada operación, solo leyendo el código, sin esperar a habilitar configuraciones de JPA.

Bueno el Mapper es necesario para cuando queremos consultar varios registros, en tanto que si sabemos que regresara un solo registro, podemos llamar directamente la clase que usara en nuestro caso Question.

Configuración de MyBatis

Ahora vamos a crear la configuración de MyBatis, necesitamos crear un archivo xml llamado SQLMapConfig en la carpeta src/main/resources, agregamos lo siguiente:

 

Se que MyBatis también permite usar anotaciones en los beans, pero yo preferí dejar la configuración en xml sin una razón en particular, lo que si es que no intente la configuración con anotaciones, por lo que no puedo afirmar que funciona :P, menos con Kotlin.

Aquí definimos el typo Question asociado a nuestra data class, los ambientes que se pueden definir en MyBatis y el mapper Question que definimos en el paso anterior.

Actualizando Question data class

Un tip que me llevo algo de tiempo entender, es que MyBatis espera que las clases Java tengan un constructor vacío y todas las propiedades con getters y setters, pero el modo en que definimos la data class en Kotlin no tiene un constructor vacío, pero gracias a la JVM lo único que tenemos que hacer es asegurarnos de inicializar todas las propiedades de la clase (nos falta el idQuestion) así que solo bastaría inicializar idQuestion con -1.

Sin pensarlo asi, Question quedo immutable en cualquier momento, por tanto si encontramos un objeto Question con Id -1, quiere decir que esa Question no viene de Base de datos.

Actualizando QuestionAPI

En el archivo QuestionAPI, solo hay que agregar la nueva operación:

 

también modifique el PATH de nuestra API, ahora es "/question" en lugar de "/", esto porque vamos a integrar mas de una ruta en el mismo endpoint http, en la definición de la clase modifica esto:

 

Actualizando QuestionOperations

Incluimos la nueva operación ADD_QUESTION con valor addQuestion

 

Actualizando QuestionOut

Ahora tenemos una operación mas, por lo que debemos incluir el apropiado manejo de los status http, simplemente regresamos 201 en lugar de 200 cuando insertamos un objeto en la base de datos,

 

También quite el código del filtro y la lista de preguntas, ahora MyBatis y MySQL hacen ese filtro y guardan las preguntas.

Actualizando QuestionRoute

La ruta del modulo Question ahora conectara las consultas de MyBatis.

 

Para cada operación estamos haciendo el tipo de consulta requerida, addQuestion es de tipo insert, getQuestionById es de tipo SelectOne, y getAllQuestions es de tipo SelectList. Recuerdas que definimos QuestionIn y lo único que hacia era instanciar Question con el id que recibía. Pues bien la razón es que el query de MyBatis para seleccionar una pregunta por Id, recibe un Question, no un entero " " (pudimos dejarlo en entero también pero es para ejemplificar validación de datos).

También modifique el endpoint de entrada de esta ruta, ahora es direct:Question, direct: sirve para conectar rutas en el mismo Contexto de Camel, por tanto esta ruta ya no escucha en http sino que escuchara todos los mensajes que se escriban a direct:Question siempre y cuando sean del mismo Contexto.

Agregando el nuevo endpoint HTTP

El la carpeta src/main/java hay que crear un nuevo Kotlin File/Class llamado CxfrServer:

 

Esta nueva ruta es ahora el endpoint http, he modificado el path, ya no incluye Question, porque eso esta en el API del modulo Question, de momento los resources de este endpoint solo incluye una clase QuestionApi, después voy a agregar otros resources.

Dependiendo del path que viene en el header "CamelHttpPath" enviara, con ayuda de direct:, a la ruta adecuada cada mensaje que llegue, en este caso todos los mensajes que lleguen en /wizard/question serán enviados a direct:questionRoute, recordemos que direct:questionRoute es la ruta del modulo Question.

Modificando Main.kt

Finalmente, podemos actualizar el archivo src/main/java/Main.kt de nuestro pequeño proyecto:

 

Hay varios cambios, numero uno estamos registrando el JSON provider para la operación addQuestion, para eso el registry tiene que ser del typo Jndi (el porque del jndi.properties), y el ultimo cambio es que ahora registramos dos rutas, una es el http endpoint del servicio CXF y la otra es la ruta del modulo Question.

Resultados

Bueno ejecutando la aplicación (click secundario src/main/java/Main.kt -> run Main.kt), podemos comprobar que todas nuestras rutas y modificaciones funcionan, en este caso use postman y estos son los resultados

PUT

Body:

{
"text": "Que?",
"correctAnswer": "1"
}

Respuesta: status 201
 

GET

Respuesta: status 200
 

GET
Respuesta: status 200
 

GET
Respuesta: status 404

Notas finales

El codigo ha sido actualizado este es el commit tiene mucha paja de intellij :P, puedes ignorar todos los archivos de la carpeta .idea .