Main

Merge-Test

src/main/java/schueler/App.java

 package schueler;
 
-import java.sql.Connection;
-import java.sql.DriverManager;
-import java.sql.ResultSet;
-import java.sql.SQLException;
-import java.sql.Statement;
-import org.sqlite.SQLiteConfig;
+import com.sun.net.httpserver.HttpServer;
+
+import java.io.IOException;
+import java.net.InetSocketAddress;
+import java.util.logging.Level;
+import java.util.logging.Logger;
 
 public class App {
-    
-    public static void main(String[] args) {
 
+    public static void main(String[] args) {
+        HttpServer server;
+        Logger log = Logger.getLogger("server");
 
         try {
-            Class.forName("org.sqlite.JDBC");
-            SQLiteConfig config = new SQLiteConfig();
-            config.enforceForeignKeys(true);
-            Connection c = DriverManager.getConnection("jdbc:sqlite:todo_klein_org.db", config.toProperties());
-            insertPriority(10,"sehr unwichtig",c);
-            Statement st = c.createStatement();
-            ResultSet rs = st.executeQuery("select * from priority");
-            while (rs.next()) {
-                System.out.println(rs.getInt(1) + " " + rs.getInt(2) + " " + rs.getString(3));
-            }
-        } catch (ClassNotFoundException e) {
-            System.out.println("Treiber nicht gefunden");
-            e.printStackTrace();
-        } catch (SQLException e) {
-            e.printStackTrace();
-        }
-    }
-    public static boolean insertPriority(int p, String description, Connection c){
-        try{
-            Statement st = c.createStatement();
-            return st.execute("insert into priority(value,description) values ("+p+",\""+description+"\");");
-        } catch (SQLException e) {
+            server = HttpServer.create(new InetSocketAddress(8000), 0);
+            server.createContext("/", new Server());
+            server.setExecutor(null);
+            server.start();
+            log.log(Level.INFO, "Server started...");
+        } catch (IOException e) {
             e.printStackTrace();
-            return false;
         }
     }
-}
+  }

src/main/java/schueler/Entity.java

 package schueler;
 
+import java.sql.ResultSet;
+
 public abstract class Entity {
 
     private String name;
     public abstract String getDeleteStatement();
     public abstract String getReadStatement();
     public abstract String getReadAllStatement();
+    public abstract void setEntity(ResultSet rs);
+    public abstract String toJson();
+    public abstract void parseJson(String json);
 }

src/main/java/schueler/Priority.java

 package schueler;
 
+import com.google.gson.Gson;
+
+import java.sql.ResultSet;
+import java.sql.SQLException;
+
 public class Priority extends Entity{
-    
+
     private int value;
 
     public Priority(int value,String name) {
 
     @Override
     public String getCreateStatement() {
-        // TODO Auto-generated method stub
-        return null;
+
+        return "INSERT INTO Priority (name, value) VALUES ('" + getName() + "', " + getValue() + ");";
     }
 
     @Override
     public String getUpdateStatement() {
-        // TODO Auto-generated method stub
-        return null;
+        return "UPDATE priority SET value = " + value + "' WHERE id = " + getId() + ";";
     }
 
+
     @Override
     public String getDeleteStatement() {
-        // TODO Auto-generated method stub
-        return null;
+        return "DELETE FROM priority WHERE id = \""+getId()+"\";";
     }
 
+
     @Override
     public String getReadStatement() {
-        // TODO Auto-generated method stub
-        return null;
+
+        return "select * from priority where id = " + super.getId();
     }
 
     @Override
     public String getReadAllStatement() {
-        // TODO Auto-generated method stub
-        return null;
+        return "SELECT * FROM priority";
+    }
+private static class TaskPriority {
+        String description;
+        int id;
+        int value;
+    }
+    public void setEntity(ResultSet rs){
+        try {
+            this.id = rs.getInt("id");
+            this.setName( rs.getString("description"));
+            this.setValue(rs.getInt("value"));
+        } catch (SQLException e) {
+            e.printStackTrace();
+        }
+    }
+    @Override
+    public void parseJson(String json) {
+        TaskPriority p = new Gson().fromJson(json, TaskPriority.class);
+        this.setId(p.id);
+        this.setValue(p.value);
+        this.setName(p.description);
+    }
+
+    @Override
+    public String toJson() {
+        TaskPriority p = new TaskPriority();
+        p.id=getId();
+        p.description=getName();
+        p.value=getValue();
+        return new Gson().toJson(this);
     }
 }
+

src/main/java/schueler/Project.java

 package schueler;
 
+import com.google.gson.Gson;
+
 import java.sql.ResultSet;
 import java.sql.SQLException;
 
 
     @Override
     public String getCreateStatement() {
-        return null;
+        return "INSERT INTO Project (name) VALUES ('" + getName() + "');";
     }
 
     @Override
     public String getUpdateStatement() {
-        return null;
+        return "UPDATE project SET name = '" + this.getName() + "' WHERE id = " + this.id;
     }
 
+
     @Override
     public String getDeleteStatement() {
-        return null;
+        return "DELETE FROM project WHERE id = \""+getId()+"\";";
     }
 
     @Override
     public String getReadStatement() {
-        return null;
+        return "select * from project WHERE id = \"" + getId() + "\";";
     }
 
     @Override
     public String getReadAllStatement() {
-        // TODO Auto-generated method stub
-        return null;
+        return "SELECT * FROM Project";
+    }
+    public void setEntity(ResultSet rs){
+        try {
+            this.id = rs.getInt("id");
+            this.setName( rs.getString("name"));
+        } catch (SQLException e) {
+
+            e.printStackTrace();
+        }
+    }
+        @Override
+    public void parseJson(String json) {
+        Project p = new Gson().fromJson(json, Project.class);
+        this.setId(p.getId());
+        this.setName(p.getName());
+    }
+
+
+    @Override
+    public String toJson() {
+        return new Gson().toJson(this);
     }
-}
\ No newline at end of file
+}

src/main/java/schueler/SQLHelper.java

+package schueler;
+
+import java.sql.Connection;
+import java.sql.DriverManager;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.sql.Statement;
+
+import org.sqlite.SQLiteConfig;
+
+public class SQLHelper{
+
+     public static Connection makConnection() throws Exception{
+        try {
+            Class.forName("org.sqlite.JDBC");
+            SQLiteConfig config = new SQLiteConfig();
+            config.enforceForeignKeys(true);
+            return DriverManager.getConnection("jdbc:sqlite:todo_klein_org.db", config.toProperties());
+        }catch(Exception e){
+            throw e;
+        }
+    }
+
+
+    public static boolean executeSQL(String statment, Connection c){
+        try{
+            Statement st = c.createStatement();
+            return st.execute(statment);
+        } catch (SQLException e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    public static ResultSet executeSQLQuery(String statment, Connection c){
+        try{
+            Statement st = c.createStatement();
+            return st.executeQuery(statment);
+        } catch (SQLException e) {
+            e.printStackTrace();
+            return null;
+        }
+    }
+    public static int executeSQLUpdate(String statment, Connection c){
+        try{
+            Statement st = c.createStatement();
+            return st.executeUpdate(statment);
+        } catch (SQLException e) {
+            e.printStackTrace();
+            return 0;
+        }
+    }   
+}
\ No newline at end of file