update

src/kr/co/swh/lecture/database/java/FunctionTest.java

@@ -5,6 +5,7 @@ import java.sql.DriverManager;
 import java.sql.ResultSet;
 import java.sql.SQLException;
 import java.sql.Statement;
+import java.util.List;
 
 /**
  * <pre>
@@ -27,6 +28,33 @@ public class FunctionTest {
 	static final String PASSWORD = "xxxxxxx";
 
 	
+	public boolean dbInsert(List<Store> stores) {
+		boolean result = false;
+		Connection connection;
+		try {
+			Class.forName("com.mysql.jdbc.Driver");
+			connection = DriverManager.getConnection(DB_URL,USERNAME,PASSWORD);
+			connection.setAutoCommit(false);
+			System.out.println("MariaDB 연결.");
+			Statement statement = connection.createStatement();
+			for(Store object : stores) {
+				String sql = String.format("insert into store(addr, code, lat, lng, name, type) values('%s','%s','%s','%s','%s','%s')", store.getAddr(), store.getCode(), lat, lng, name, type);
+				result = statement.execute(sql);
+			}
+			connection.commit();
+
+		} catch (ClassNotFoundException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+		} catch (SQLException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+			connection.rollback();
+		}
+		return result;
+
+	}
+	
 	public boolean dbInsert(Store store) {
 		boolean result = false;
 		Connection connection;
@@ -44,6 +72,7 @@ public class FunctionTest {
 		} catch (SQLException e) {
 			// TODO Auto-generated catch block
 			e.printStackTrace();
+			
 		}
 		return result;
 
@@ -92,13 +121,66 @@ public class FunctionTest {
 
 	}
 	
+	public int dbUpdate(Store store) {
+		int result = 0;
+		Connection connection;
+		try {
+			Class.forName("com.mysql.jdbc.Driver");
+			connection = DriverManager.getConnection(DB_URL,USERNAME,PASSWORD);
+			System.out.println("MariaDB 연결.");
+			Statement statement = connection.createStatement();
+			result = statement.executeUpdate("update a set c1 = v1;");		//	result = 업데이터된 행의 숫자
+
+		} catch (ClassNotFoundException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+		} catch (SQLException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+		}
+		return result;
+
+	}
+	
+	public static void name() {
+		
+	}
+	
+	
+	
+	
+	
 	public static void main(String[] args) {
+		Store s1 = new Store();
+		
+		StoreDB s = new StoreDB();
+		s.dbInsert(s1);
+		
+		StoreDB s2 = new StoreDB();
+		s2.dbInsert(s1);
+		
+
+		
+		name();
+		
+		
+		
+		
 		
 		FunctionTest test = new FunctionTest();
-//		test.dbInsert("sdf", "sdf", "sdf", "sdf", "sdf", "sdf");
-		test.dbInsert(store)
 		
+		test.name();
+		
+		
+		
+		Store s = new Store();
+		s.setAddr("123");
 		
+		boolean r = test.dbInsert(s);
+		
+		
+		
+//		test.dbInsert("sdf", "sdf", "sdf", "sdf", "sdf", "sdf");
 		Connection connection = null;
 		Statement statement = null;
 		try{

src/kr/co/swh/lecture/database/java/StoreDB.java

@@ -0,0 +1,186 @@
+package kr.co.swh.lecture.database.java;
+
+import java.sql.Connection;
+import java.sql.DriverManager;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.sql.Statement;
+import java.util.List;
+
+/**
+ * <pre>
+ * kr.co.swh.lecture.database.java
+ * MariaDBSelect.java
+ *
+ * 설명 :데이터베이스 검색 예제
+ * </pre>
+ * 
+ * @since : 2017. 10. 26.
+ * @author : tobby48
+ * @version : v1.0
+ */
+public class StoreDB {
+
+	final static String JDBC_DRIVER = "com.mysql.jdbc.Driver";  
+	static final String DB_URL = "jdbc:mysql://127.0.0.1:3306/market";
+
+	static final String USERNAME = "root";
+	static final String PASSWORD = "xxxxxxx";
+
+	public Connection init() {
+		Connection connection = null;
+		try {
+			Class.forName("com.mysql.jdbc.Driver");
+			connection = DriverManager.getConnection(DB_URL,USERNAME,PASSWORD);
+			System.out.println("MariaDB 연결.");
+			
+		} catch (ClassNotFoundException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+		} catch (SQLException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+		}
+		return connection;
+	}
+	
+	public boolean dbInsert(List<Store> stores) {
+		boolean result = false;
+		Statement statement = null;
+		Connection connection = init();
+		try {
+			statement = connection.createStatement();
+			for(Store object : stores) {
+				String sql = String.format("insert into store(addr, code, lat, lng, name, type) values('%s','%s','%s','%s','%s','%s')", store.getAddr(), store.getCode(), lat, lng, name, type);
+				result = statement.execute(sql);
+			}
+			connection.commit();
+			
+		} catch (ClassNotFoundException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+		} catch (SQLException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+			connection.rollback();
+		} finally {
+			statement.close();
+		}
+		
+		
+		
+		
+		
+		Connection connection;
+		try {
+			Class.forName("com.mysql.jdbc.Driver");
+			connection = DriverManager.getConnection(DB_URL,USERNAME,PASSWORD);
+			connection.setAutoCommit(false);
+			System.out.println("MariaDB 연결.");
+			Statement statement = connection.createStatement();
+			for(Store object : stores) {
+				String sql = String.format("insert into store(addr, code, lat, lng, name, type) values('%s','%s','%s','%s','%s','%s')", store.getAddr(), store.getCode(), lat, lng, name, type);
+				result = statement.execute(sql);
+			}
+			connection.commit();
+
+		} catch (ClassNotFoundException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+		} catch (SQLException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+			connection.rollback();
+		}
+		return result;
+
+	}
+	
+	public boolean dbInsert(Store store) {
+		boolean result = false;
+		Connection connection;
+		try {
+			Class.forName("com.mysql.jdbc.Driver");
+			connection = DriverManager.getConnection(DB_URL,USERNAME,PASSWORD);
+			System.out.println("MariaDB 연결.");
+			Statement statement = connection.createStatement();
+			String sql = String.format("insert into store(addr, code, lat, lng, name, type) values('%s','%s','%s','%s','%s','%s')", store.getAddr(), store.getCode(), lat, lng, name, type);
+			result = statement.execute(sql);
+
+		} catch (ClassNotFoundException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+		} catch (SQLException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+			
+		}
+		return result;
+
+	}
+	
+	public boolean dbInsert(String addr, String code, String lat, String lng, String name, String type) {
+		boolean result = false;
+		Connection connection;
+		try {
+			Class.forName("com.mysql.jdbc.Driver");
+			connection = DriverManager.getConnection(DB_URL,USERNAME,PASSWORD);
+			System.out.println("MariaDB 연결.");
+			Statement statement = connection.createStatement();
+			String sql = String.format("insert into store(addr, code, lat, lng, name, type) values('%s','%s','%s','%s','%s','%s')", addr, code, lat, lng, name, type);
+			result = statement.execute(sql);
+
+		} catch (ClassNotFoundException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+		} catch (SQLException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+		}
+		return result;
+
+	}
+	
+	public int dbUpdate() {
+		int result = 0;
+		Connection connection;
+		try {
+			Class.forName("com.mysql.jdbc.Driver");
+			connection = DriverManager.getConnection(DB_URL,USERNAME,PASSWORD);
+			System.out.println("MariaDB 연결.");
+			Statement statement = connection.createStatement();
+			result = statement.executeUpdate("update a set c1 = v1;");		//	result = 업데이터된 행의 숫자
+
+		} catch (ClassNotFoundException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+		} catch (SQLException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+		}
+		return result;
+
+	}
+	
+	public int dbUpdate(Store store) {
+		int result = 0;
+		Connection connection;
+		try {
+			Class.forName("com.mysql.jdbc.Driver");
+			connection = DriverManager.getConnection(DB_URL,USERNAME,PASSWORD);
+			System.out.println("MariaDB 연결.");
+			Statement statement = connection.createStatement();
+			result = statement.executeUpdate("update a set c1 = v1;");		//	result = 업데이터된 행의 숫자
+
+		} catch (ClassNotFoundException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+		} catch (SQLException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+		}
+		return result;
+
+	}
+	
+}