ex

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

@@ -19,52 +19,51 @@ import java.util.List;
  * @author : tobby48
  * @version : v1.0
  */
-public class FunctionTest {
+public class DatabaseUtil {
+	String JDBC_DRIVER = "com.mysql.jdbc.Driver";  
+	String DB_URL;
 
-	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";
+	String USERNAME;
+	String PASSWORD;
 
+	Connection connection = null;
 	
-	public boolean dbInsert(List<Store> stores) {
-		boolean result = false;
-		Connection connection;
+	public DatabaseUtil(String dbType, String dbUrl, String dbName, String user, String password2) {
+		// TODO Auto-generated constructor stub
+
+		
+		DB_URL = "jdbc:mysql://" + dbUrl + ":3306/" + dbName;
+		USERNAME = user;
+		PASSWORD = password2;
+		
 		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) {
+		} catch (ClassNotFoundException | SQLException e) {
 			// TODO Auto-generated catch block
 			e.printStackTrace();
+		}
+	}
+	
+	public void close() {
+		try {
+			connection.close();
 		} catch (SQLException e) {
 			// TODO Auto-generated catch block
 			e.printStackTrace();
-			connection.rollback();
 		}
-		return result;
-
 	}
-	
-	public boolean dbInsert(Store store) {
+
+	public boolean dbInsert(List<Store> stores) {
+		
 		boolean result = false;
-		Connection connection;
+		Statement statement = null;
 		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);
+			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);
+			}
 
 		} catch (ClassNotFoundException e) {
 			// TODO Auto-generated catch block
@@ -72,21 +71,18 @@ public class FunctionTest {
 		} catch (SQLException e) {
 			// TODO Auto-generated catch block
 			e.printStackTrace();
+		} finally {
+			statement.close();
 			
 		}
 		return result;
-
 	}
-	
-	public boolean dbInsert(String addr, String code, String lat, String lng, String name, String type) {
+
+	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')", addr, code, lat, lng, name, type);
+			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) {
@@ -95,99 +91,56 @@ public class FunctionTest {
 		} 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;
 
-	}
-	
-	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 tt = new FunctionTest();
+		tt.play();
+
+
+
+
+
+
+
+
+
 		FunctionTest test = new FunctionTest();
-		
+
 		test.name();
-		
-		
-		
+
+
+
 		Store s = new Store();
 		s.setAddr("123");
-		
+
 		boolean r = test.dbInsert(s);
-		
-		
-		
-//		test.dbInsert("sdf", "sdf", "sdf", "sdf", "sdf", "sdf");
+
+
+
+		//		test.dbInsert("sdf", "sdf", "sdf", "sdf", "sdf", "sdf");
 		Connection connection = null;
 		Statement statement = null;
 		try{
 			Class.forName("com.mysql.jdbc.Driver");
 			connection = DriverManager.getConnection(DB_URL,USERNAME,PASSWORD);
 			System.out.println("MariaDB 연결.");
-			
+
 			statement = connection.createStatement();
 			while() {
 				statement.execute(sql)
@@ -195,21 +148,21 @@ public class FunctionTest {
 			statement.close();
 			statement = connection.createStatement();
 
-			
+
 			//	insert
 			boolean result = statement.execute("insert into employees(name,c2) values('가준', v2);");
-//			boolean result = statement.execute(String.format("insert into a(c1,c2) values(%d, %s);", v1, v2));
+			//			boolean result = statement.execute(String.format("insert into a(c1,c2) values(%d, %s);", v1, v2));
 			if(result) System.out.println("ResultSet 값 있다.");
 			else System.out.println("업데이트 된 행이 있거나 리턴되는 값이 없는 경우");
-					
+
 			//	update
-//			int result = statement.executeUpdate("update a set c1 = v1;");		//	result = 업데이터된 행의 숫자
-//			if(result > 0) System.out.println("정상처리");
-//			else System.out.println("비정상처리");
-				
+			//			int result = statement.executeUpdate("update a set c1 = v1;");		//	result = 업데이터된 행의 숫자
+			//			if(result > 0) System.out.println("정상처리");
+			//			else System.out.println("비정상처리");
+
 			//	select
 			ResultSet rs = statement.executeQuery("SELECT * FROM employees;");
-			
+
 			while(rs.next()){
 				int employee_id = rs.getInt("employee_id");
 				String name = rs.getString("name");

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

@@ -0,0 +1,17 @@
+package kr.co.swh.lecture.database.java;
+
+public class School {
+
+	public static void main(String[] args) {
+		// TODO Auto-generated method stub
+		
+		String dbUrl = "127.0.0.1";
+		String dbName = "heejae";
+		String user = "root";
+		String password = "swhacademy!";
+		
+		DatabaseUtil u = new DatabaseUtil(dbUrl, dbName, user, password);
+//		u.dbInsert(stores)
+	}
+
+}

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

@@ -0,0 +1,30 @@
+package kr.co.swh.lecture.database.java;
+
+public class Wheather {
+
+	public static void main(String[] args) {
+		// TODO Auto-generated method stub
+		
+		//	수집코드
+		
+		//	데이터베이스 저장
+		String dbUrl = "127.0.0.1";
+		String dbName = "market";
+		String user = "root";
+		String password = "swhacademy!";
+
+		
+		
+		DatabaseUtil u = new DatabaseUtil(dbUrl, dbName, user, password);
+		u.DB_URL
+		u.dbInsert(stores)
+		u.close();
+		
+		
+		
+		DatabaseUtil u1 = new DatabaseUtil();
+		u1.dbInsert(store);
+//		u.dbInsert(stores)
+	}
+
+}