Added file reading and data creation and insertion in sqlite.

Author: HeitorLouzeiro

demo/src/main/java/com/example/database/FileUltils.java

@@ -0,0 +1,25 @@
+package com.example.database;
+
+import java.io.BufferedReader;
+import java.io.FileReader;
+import java.io.IOException;
+
+public class FileUltils {
+    public static String loadTextFile(final String filename) throws IOException{
+        long time = System.currentTimeMillis();
+        BufferedReader br = new BufferedReader(new FileReader(filename));
+        StringBuilder sb = new StringBuilder();
+        String line;
+
+        while((line = br.readLine()) != null){
+            sb.append(line);
+            sb.append("\n");
+        }
+        br.close();
+        time = System.currentTimeMillis() - time;
+
+        System.out.println("Read file: " + filename + " in " + time + "ms");
+        return sb.toString();
+    }
+    
+}

demo/src/main/java/com/example/database/Person.java

@@ -0,0 +1,28 @@
+package com.example.database;
+
+public class Person {
+    private int id;
+    private String name;
+    
+    public int getId() {
+        return id;
+    }
+
+    public void setId(int id) {
+        this.id = id;
+    }
+
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(String name) {
+        this.name = name;
+    }
+
+    public Person() {
+
+    }
+    
+}

demo/src/main/java/com/example/database/PersonDao.java

@@ -0,0 +1,21 @@
+package com.example.database;
+
+import java.sql.Connection;
+import java.sql.SQLException;
+import java.sql.Statement;
+
+public class PersonDao {
+    private Connection connetion;
+    public PersonDao() {
+        connetion = Database.getInstance().getConnection();
+
+    }
+
+    public void insert(Person person) throws SQLException{
+        Statement statement = connetion.createStatement();
+
+        statement.executeUpdate("insert into person values(" + person.getId() + ", '" + person.getName() + "')");
+
+        statement.close();
+    }
+}

demo/src/main/java/com/example/database/TestDB.java

@@ -1,22 +1,35 @@
 package com.example.database;
 
+import java.io.IOException;
 import java.sql.Connection;
 import java.sql.ResultSet;
 import java.sql.SQLException;
 import java.sql.Statement;
 
 public class TestDB {
-    public static void main(String[] args) {
+    public static void main(String[] args) throws IOException{
 
         Connection connection = null;
         try {
             connection = Database.getInstance().getConnection();
             Statement statement = connection.createStatement(); // set timeout to 30 sec.
 
-            statement.executeUpdate("drop table if exists person");
-            statement.executeUpdate("create table person (id integer, name string)");
-            statement.executeUpdate("insert into person values(1, 'leo')");
-            statement.executeUpdate("insert into person values(2, 'yui')");
+            // create a database connection
+            String sql = FileUltils.loadTextFile("demo/src/main/java/com/example/resource/description.sql");
+            /* System.out.println(sql); */
+
+            // Run the query
+            statement.executeUpdate(sql);
+
+            // Insert data
+             Person person = new Person();
+            person.setId(3);
+            person.setName("Gean");
+
+            // data access object
+            PersonDao personDao = new PersonDao();
+            personDao.insert(person);
+
             ResultSet rs = statement.executeQuery("select * from person");
             while (rs.next()) {
                 // read the result set

demo/src/main/java/com/example/resource/description.sql

@@ -0,0 +1,11 @@
+drop table if exists person;
+create table person (id integer, name string);
+insert into person values(1, 'leo');
+insert into person values(2, 'yui')
+
+
+/* CREATE TABLE IF NOT EXISTS person (
+  id INTEGER,
+  name STRING
+);
+ */

demo/target/classes/com/example/resource/description.sql

@@ -0,0 +1,11 @@
+drop table if exists person;
+create table person (id integer, name string);
+insert into person values(1, 'leo');
+insert into person values(2, 'yui')
+
+
+/* CREATE TABLE IF NOT EXISTS person (
+  id INTEGER,
+  name STRING
+);
+ */