Create Android.java (#737)

Author: StrakarCe

src/main/java/org/influxdb/example/Android.java

@@ -0,0 +1,98 @@
+package org.influxdb.example;
+
+import org.influxdb.InfluxDB;
+import org.influxdb.InfluxDBFactory;
+import org.influxdb.dto.QueryResult;
+import org.influxdb.dto.Query;
+
+import java.util.LinkedList;
+import java.util.List;
+
+/**
+ * @author StrakarCe
+ * @since 07/05/2021
+ * @version 1
+ */
+public class Android {
+        // put the address IP of your database
+        String address = "http://192.168.1.75:8000/";
+        String dbName = "myDatabase";
+        String table = "SERIES";
+        QueryResult actual;
+        Boolean flag = false;
+        InfluxDB con;
+
+        public Android() {
+                super();
+        }
+        public void queryExecute(final Query query) {
+                Thread thread = new Thread(new Runnable() {
+
+                        @Override
+                        public void run() {
+                                try  {
+                                        //InfluxDB connector = InfluxDBFactory.connect(address);
+                                        // if you want to open every time
+                                        System.out.println("Send the query to the database ...");
+                                        // FOR A REAL APP CREATE A LOGGER ;
+                                        List<QueryResult> results = new LinkedList<>();
+                                        actual = con.query(query);
+                                } catch (Exception e) {
+                                e.printStackTrace();
+                        }
+                        flag = true; // For simplicity, I use a simple flag to know when the thread have finished
+                }
+                });
+
+                thread.start();
+        }
+
+        /**
+        * It's to open the connexion with the database.
+        * In my case I decide to open once, do many query and close.
+        */
+        public void connexion() {
+                con = InfluxDBFactory.connect(address);
+        }
+        /**
+        * It's to close after my  list of query.
+        */
+        public void close() {
+                con.close();
+        }
+        /*
+        * simple example of how you can create a query
+        */
+        private void queryLauncher(final String query) {
+                queryExecute(new Query(query, dbName));
+                while (!flag) { // ugly method to wait the thread
+                        System.out.println("Wait the thread");
+                }
+                flag = false;
+        }
+        public String getEtat() {
+                queryLauncher("select last(value) from PTEC");
+                return actual.getResults().get(0).getSeries().get(0).getValues().get(0).get(1).toString();
+        }
+        public String getHC() {
+                queryLauncher("SELECT last(value) FROM HCHC");
+                return actual.getResults().get(0).getSeries().get(0).getValues().get(0).get(1).toString();
+        }
+        // ------------------------- Example when you want to use it ------------
+        /*
+        Android test = new Android();
+        refresh.setOnClickListener(new View.OnClickListener() {
+                @Override
+                public void onClick(View v) {
+                        test.connexion();
+                        etat2.setText(test.getEtat());
+                        hc2.setText(test.getHC());
+                        hp2.setText(test.getHP());
+                        prix2.setText(test.getDepense());
+                        percMens2.setText(test.getPercentageMensuel());
+                        percTotal2.setText(test.getPercentageTotal());
+                        test.close();
+                }
+        });
+        */
+}