Csf

restful/src/main/java/server/restful/dao/CarDAO.java

+package server.restful.dao;
+
+import server.restful.model.CarModel;
+
+import java.sql.Connection;
+import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.util.ArrayList;
+import java.util.List;
+
+public class CarDAO extends BaseDAO {
+
+    public static int create(String name, String path){
+        int carId = -1;
+        Connection c = getConnection();
+        PreparedStatement stmt;
+
+        try {
+            stmt = c.prepareStatement("INSERT INTO car (name, path) VALUES (?, ?)");
+            stmt.setString(1, name);
+            stmt.setString(2, path);
+            carId = executeInsert(c, stmt);
+            c.commit();
+            c.close();
+        } catch (SQLException e) {
+            e.printStackTrace();
+        }
+
+        return carId;
+    }
+
+
+    public static CarModel getByID(int id) {
+        CarModel result = null;
+        Connection c = getConnection();
+        PreparedStatement stmt;
+        try {
+            stmt = c.prepareStatement("SELECT name, path FROM car where id=(?)");
+            stmt.setInt(1, id);
+            ResultSet rs = stmt.executeQuery();
+
+            if (rs.next()){
+                result = new CarModel(
+                        id,
+                        rs.getString("name"),
+                        rs.getString("path")
+                );
+            }
+
+            stmt.close();
+            c.close();
+        } catch (SQLException e) {
+            e.printStackTrace();
+        }
+        return result;
+    }
+
+    public static List<CarModel> getAll(){
+        List<CarModel> result = new ArrayList<>();
+        Connection c = getConnection();
+        PreparedStatement stmt;
+        try {
+            stmt = c.prepareStatement("SELECT id, name, path FROM car");
+            ResultSet rs = stmt.executeQuery();
+
+            while (rs.next()){
+                result.add(new CarModel(
+                        rs.getInt("id"),
+                        rs.getString("name"),
+                        rs.getString("path")
+                ));
+            }
+
+            stmt.close();
+            c.close();
+        } catch (SQLException e) {
+            e.printStackTrace();
+        }
+        return result;
+    }
+}