{"id":12493,"date":"2017-05-26T09:27:59","date_gmt":"2017-05-26T07:27:59","guid":{"rendered":"http:\/\/www.devapp.it\/wordpress\/?p=12493"},"modified":"2017-05-26T09:27:59","modified_gmt":"2017-05-26T07:27:59","slug":"creare-api-rest-con-spark-java-gson-e-rethinkdb","status":"publish","type":"post","link":"https:\/\/www.devapp.it\/wordpress\/creare-api-rest-con-spark-java-gson-e-rethinkdb\/","title":{"rendered":"Creare API REST con Spark Java, Gson e RethinkDB"},"content":{"rendered":"

Al giorno d’oggi esistono molti servizi moderni, affidabili e reattivi, basati su programmi di piccole dimensioni e dalla configurazione agevole. Ne abbiamo gi\u00e0 conosciuti alcuni su questo sito<\/a> come Spark Java che permette di creare velocemente API REST<\/strong> e RethinkDB<\/a> che offre database JSON ideali per funzionalit\u00e0 real-time. In questo articolo, li metteremo insieme facendoci aiutare anche da Gson<\/a>, altra efficacissima libreria per il formato JSON offerta da Google: realizzeremo un’applicazione di esempio il cui codice potr\u00e0 essere scaricato qui<\/a>.<\/p>\n

Cosa vogliamo realizzare?<\/h2>\n

Il nostro scopo \u00e8 quello di gestire un database RethinkDB tramite il suo\u00a0driver per Java<\/a>. Per il resto, Spark Java ci offrir\u00e0 gli strumenti per l’interfacciamento in rete e tutto il codice di gestione dei dati sar\u00e0 racchiuso nella nostra classe LocalDataService<\/em>. Il database sar\u00e0 composto da una sola tabella la cui finalit\u00e0 sar\u00e0 conservare due stringhe – text1<\/em> e text2<\/em> – ad uso molto generico (potrebbe trattarsi di una nota con il suo contenuto o altro simile) nonch\u00e8 un id univoco in formato stringa assegnato da RethinkDB.<\/p>\n

La prima cosa che ci serve \u00e8 risolvere le dipendenze<\/strong>. Il nostro progetto avr\u00e0 bisogno delle tre librerie che abbiamo nominato per cui potremo scaricare i relativi file jar dai siti ufficiali o ricorrere ad un sistema di gestione come Maven. Noi, ad esempio, abbiamo percorso quest’ultima via creando\u00a0un progetto Maven per Eclipse nel cui\u00a0file pom.xml abbiamo inserito le seguenti dipendenze:<\/p>\n

<dependencies>\r\n    <dependency>\r\n      <groupId>com.google.code.gson <\/groupId>\r\n      <artifactId>gson<\/artifactId>\r\n      <version>2.7<\/version>\r\n    <\/dependency>\r\n    <dependency>\r\n      <groupId>com.sparkjava<\/groupId>\r\n      <artifactId>spark-core<\/artifactId>\r\n      <version>2.5<\/version>\r\n    <\/dependency>\r\n    <dependency>\r\n      <groupId>com.rethinkdb<\/groupId>\r\n      <artifactId>rethinkdb-driver<\/artifactId>\r\n      <version>2.3.3<\/version>\r\n    <\/dependency>\r\n<\/dependencies><\/pre>\n
Un database con RethinkDB<\/h2>\n
Per eseguire l’applicazione, \u00e8 necessario installare RethinkDB<\/a>. Il procedimento \u00e8 rapidissimo ed una volta lanciato il server si pu\u00f2 invocare da browser l’indirizzo http:\/\/localhost:8080\/<\/em> per accedere al suo pannello di amministrazione. Gestiremo il rapporto con questa sorgente dati tramite la classe Connector<\/em>:<\/p>\n
public class Connector {\r\n\tprivate String dbname=\"test\";\r\n\tprivate String hostname=\"localhost\";\r\n\tprivate int port=28015;\r\n\tprivate String tableName;\r\n\tprivate Connection conn=null;\r\n\tprivate RethinkDB r =null;\r\n\t\r\n\tpublic Connector(String db, String tableName)\r\n\t{\r\n\t\tdbname=db;\r\n\t\tthis.tableName=tableName;\r\n\t\tr= RethinkDB.r;\r\n\t\ttry{\r\n\t    \tr.dbCreate(dbname).run(getConnection());\r\n\t    \tr.db(dbname).tableCreate(tableName).run(getConnection());\r\n\t    \t}\r\n\t    catch(ReqlOpFailedError e){}\r\n\t}\r\n\t\r\n\tpublic Connection getConnection()\r\n\t{\r\n\t  if (conn==null || !conn.isOpen())\r\n\t   conn = r.connection().hostname(hostname).port(port).connect();\r\n\t  return conn;\r\n\t}\r\n\t\r\n\tpublic Table getTable()\r\n\t{\r\n\t\treturn r.db(dbname).table(tableName);\r\n\t}\r\n\t\r\n}<\/pre>\n
Tutta la gestione dei dati verr\u00e0 effettuata tramite l’oggetto r<\/em>, di classe RethinkDB, che rappresenta la nostra porta d’accesso alla sorgente.<\/p>\n
In questa classe:<\/p>\n