JDBC 구현 slipp#7

Author: funchcode

src/main/java/next/dao/JdbcTemplate.java

@@ -2,7 +2,10 @@
 
 import java.sql.Connection;
 import java.sql.PreparedStatement;
+import java.sql.ResultSet;
 import java.sql.SQLException;
+import java.util.ArrayList;
+import java.util.List;
 
 import core.jdbc.ConnectionManager;
 import next.model.User;
@@ -27,5 +30,39 @@ void update(String query) throws SQLException {
         }
 	}
 
+	List query(String query) throws SQLException {
+		ArrayList<Object> list = new ArrayList<Object>();
+    	Connection con = null;
+    	PreparedStatement pstmt = null;
+    	ResultSet rs = null;
+    	
+    	try {
+    		con = ConnectionManager.getConnection();
+    		pstmt = con.prepareStatement(query);
+    		setValues(pstmt);
+    		rs = pstmt.executeQuery();
+    		
+    		while(rs.next()) {
+    			list.add(mapRow(rs));
+    		}
+    		
+    		return list;
+    	} finally {
+    		if (rs != null) {
+                rs.close();
+            }
+            if (pstmt != null) {
+                pstmt.close();
+            }
+            if (con != null) {
+                con.close();
+            }
+    	}
+	}
+	
+	Object queryForObject(String query) {
+		return null;
+	}
 	abstract void setValues(PreparedStatement pstmt) throws SQLException;
+	abstract Object mapRow(ResultSet rs) throws SQLException;
 }

src/main/java/next/dao/SelectJdbcTemplate.java

@@ -0,0 +1,50 @@
+package next.dao;
+
+import java.sql.Connection;
+import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.util.ArrayList;
+import java.util.List;
+
+import core.jdbc.ConnectionManager;
+import next.model.User;
+
+public abstract class SelectJdbcTemplate {
+	List query(String query) throws SQLException {
+		ArrayList<User> list = new ArrayList<User>();
+    	Connection con = null;
+    	PreparedStatement pstmt = null;
+    	ResultSet rs = null;
+    	
+    	try {
+    		con = ConnectionManager.getConnection();
+    		pstmt = con.prepareStatement(query);
+    		setValue(pstmt);
+    		rs = pstmt.executeQuery();
+    		
+    		while(rs.next()) {
+    			list.add(new User(rs.getString("userId"), rs.getString("password"), rs.getString("name"), rs.getString("email")));
+    		}
+    		
+    		return list;
+    	} finally {
+    		if (rs != null) {
+                rs.close();
+            }
+            if (pstmt != null) {
+                pstmt.close();
+            }
+            if (con != null) {
+                con.close();
+            }
+    	}
+	}
+	
+	Object queryForObject(String query) throws SQLException {
+		return null;
+	}
+	
+	abstract void setValue(PreparedStatement pstmt);
+	abstract Object mapRow(ResultSet rs);
+}

src/main/java/next/dao/UpdateJdbcTemplate.java

@@ -8,25 +8,5 @@
 import next.model.User;
 
 public abstract class UpdateJdbcTemplate {
-	static void update(User user, UserDao userDao) throws SQLException{
-		Connection con = null;
-        PreparedStatement pstmt = null;
-        try {
-        	con = ConnectionManager.getConnection();
-        	pstmt = con.prepareStatement(userDao.createQueryForUpdate());
-        	userDao.setValuesForUpdate(user, pstmt);
-        	pstmt.executeUpdate();
-        } finally {
-        	if (pstmt != null) {
-                pstmt.close();
-            }
-
-            if (con != null) {
-                con.close();
-            }
-        }
-	}
-	
-	abstract void setValuesForUpdate(User user, PreparedStatement pstmt);
-	abstract String createQueryUpdate();
+		
 }

src/main/java/next/dao/UserDao.java

@@ -11,29 +11,6 @@
 import next.model.User;
 
 public class UserDao {
-	
-	void setValuesForInsert(User user, PreparedStatement pstmt) throws SQLException {
-		pstmt.setString(1, user.getUserId());
-        pstmt.setString(2, user.getPassword());
-        pstmt.setString(3, user.getName());
-        pstmt.setString(4, user.getEmail());
-	}
-	
-	void setValuesForUpdate(User user, PreparedStatement pstmt) throws SQLException {
-		pstmt.setString(4, user.getUserId());
-		pstmt.setString(1, user.getPassword());
-		pstmt.setString(2, user.getName());
-		pstmt.setString(3, user.getEmail());
-	}
-	
-	String createQueryForInsert() {
-		return "INSERT INTO USERS VALUES (?,?,?,?)";
-	}
-	
-	String createQueryForUpdate() {
-		return "UPDATE USERS SET password = ?, name = ?, email = ? WHERE userid = ?";
-	}
-	
     public void insert(User user) throws SQLException {
     	String query = "INSERT INTO USERS VALUES (?,?,?,?)";
     	JdbcTemplate insertJdbc = new JdbcTemplate() {
@@ -44,15 +21,53 @@ void setValues(PreparedStatement pstmt) throws SQLException {
 		        pstmt.setString(3, user.getName());
 		        pstmt.setString(4, user.getEmail());
 			}
+
+			@Override
+			Object mapRow(ResultSet rs) {
+				// TODO Auto-generated method stub
+				return null;
+			}
     	};
     	insertJdbc.update(query);
     }
 
     public void update(User user) throws SQLException {
-        UpdateJdbcTemplate.update(user, new UserDao());
+    	String query = "UPDATE USERS SET password = ?, name = ?, email = ? WHERE userid = ?\";\n";
+    	JdbcTemplate insertJdbc = new JdbcTemplate() {
+			@Override
+			void setValues(PreparedStatement pstmt) throws SQLException {
+				pstmt.setString(4, user.getUserId());
+				pstmt.setString(1, user.getPassword());
+				pstmt.setString(2, user.getName());
+				pstmt.setString(3, user.getEmail());
+			}
+
+			@Override
+			Object mapRow(ResultSet rs) {
+				// TODO Auto-generated method stub
+				return null;
+			}
+    	};
+    	insertJdbc.update(query);
     }
 
     public List<User> findAll() throws SQLException {
+    	String query = "SELECT userId, password, name, email FROM USERS";
+    	JdbcTemplate findJdbc = new JdbcTemplate() {
+
+			@Override
+			void setValues(PreparedStatement pstmt) throws SQLException {
+				// TODO Auto-generated method stub
+				
+			}
+
+			@Override
+			Object mapRow(ResultSet rs) throws SQLException {
+				return new User(rs.getString("userId"), rs.getString("password"), rs.getString("name"), rs.getString("email"));
+			}
+    		
+    	};
+    	
         // TODO 구현 필요함.
     	ArrayList<User> list = new ArrayList<User>();
     	Connection con = null;