testing

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

@@ -0,0 +1,157 @@
+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;
+
+/**
+ * <pre>
+ * kr.co.swh.lecture.database.java
+ * MariaDBSelect.java
+ *
+ * 설명 :데이터베이스 검색 예제
+ * </pre>
+ * 
+ * @since : 2017. 10. 26.
+ * @author : tobby48
+ * @version : v1.0
+ */
+public class FunctionTest {
+
+	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 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 static void main(String[] args) {
+		
+		FunctionTest test = new FunctionTest();
+//		test.dbInsert("sdf", "sdf", "sdf", "sdf", "sdf", "sdf");
+		test.dbInsert(store)
+		
+		
+		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)
+			}
+			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));
+			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("비정상처리");
+				
+			//	select
+			ResultSet rs = statement.executeQuery("SELECT * FROM employees;");
+			
+			while(rs.next()){
+				int employee_id = rs.getInt("employee_id");
+				String name = rs.getString("name");
+				double hourly_pay = rs.getDouble("hourly_pay");
+				long employee_contact = rs.getLong("employee_contact");
+				System.out.println("employee_id : " + employee_id);
+				System.out.println("name: " + name);
+				System.out.println("hourly_pay: " + hourly_pay);
+				System.out.println("employee_contact: " + employee_contact);
+				System.out.println(rs.getInt(1));	// 첫번 째 열
+			}
+			rs.close();
+		}catch(SQLException se1){
+			se1.printStackTrace();
+		}catch(Exception ex){
+			ex.printStackTrace();
+		}finally{
+			try{
+				if(statement!=null) statement.close();
+				if(connection!=null) connection.close();
+			}catch(SQLException se2){
+			}
+		}
+		System.out.println("MariaDB 연결종료.");
+	}
+
+}

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

@@ -0,0 +1,48 @@
+package kr.co.swh.lecture.database.java;
+
+public class Store {
+	private String addr;
+	private String code;
+	private String lat;
+	private String lng;
+	private String name;
+	private String type;
+	
+	
+	public String getAddr() {
+		return addr;
+	}
+	public void setAddr(String addr) {
+		this.addr = addr;
+	}
+	public String getCode() {
+		return code;
+	}
+	public void setCode(String code) {
+		this.code = code;
+	}
+	public String getLat() {
+		return lat;
+	}
+	public void setLat(String lat) {
+		this.lat = lat;
+	}
+	public String getLng() {
+		return lng;
+	}
+	public void setLng(String lng) {
+		this.lng = lng;
+	}
+	public String getName() {
+		return name;
+	}
+	public void setName(String name) {
+		this.name = name;
+	}
+	public String getType() {
+		return type;
+	}
+	public void setType(String type) {
+		this.type = type;
+	}
+}