AlreadyNo의 블로그

dbinfo.properties는  아래와같이

DBDRIVER=com.mysql.jdbc.Driver

DBURL=jdbc:mysql://아이피:3306/test

DBUSER=root

DBPWD=javamysql

//1. import하자.

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.sql.Statement;

import java.util.Properties;

public class JdbcDemo {

//MySQL JDBC driver

private static final String DBDRIVER = "com.mysql.jdbc.Driver";

//MySQL Server jdbc-url --> jdbc:mysql://host_name(host_ip) : port_number/database_name

private static final String DBURL = "jdbc:mysql://172.16.46.134:3306/test";

//MySQL login user

private static final String DBUSER = "root";

//MySQL login password

private static final String DBPWD = "javamysql";

public static void main(String[] args) {

//2. Driver loading

try {

//Class.forName(DBDRIVER);

DriverManager.registerDriver(new com.mysql.jdbc.Driver());

System.out.println("Driver loading Success");

//} catch (ClassNotFoundException e) {

}catch(SQLException ex){

System.out.println("Class Not Found");

}

//3. Database Connection

Connection conn = null;

try{

Properties info = new Properties();

info.setProperty("user", "root");

info.setProperty("password", "javamysql");

conn = DriverManager.getConnection(DBURL, info);

//conn = DriverManager.getConnection(DBURL, DBUSER, DBPWD);

System.out.println("Connection Success");

}catch(SQLException ex){

System.out.println("Connection failure");

}

//4. Statement 객체 생성

Statement stmt = null;

ResultSet rs = null;

try{

stmt = conn.createStatement();

//5. SQL Statement 생성 및 실행

String sql = "SELECT zipcode, sido, gugun, dong, bunji " +

                   "FROM zipcode " +

           "WHERE dong LIKE '%상하%'    ";

//1) 만일 SQL 문장이 SELECT --> executeQuery()

//2) 나머지 SQL 문장일 때(CREATE, UPDATE, INSERT, DELETE, GRANT, REVOKE,

            //                DROP, ALTER, COMMIT, ROLLBACK ...) --> executeUpdate()

rs = stmt.executeQuery(sql);

//6. ResultSet 실행

//ResultSet 을 열면 Cursor 가 첫번째 레코드 바로 위에 위치한다.

//next()는 다음 레코드를 읽는 역할을 하며, 반드시 정방향으로 진행

//만일 역방향(previous())를 사용하려면 Scrollable ResultSet 을 생성해야 함.

//나중에 배움....

if(!rs.next()){

System.out.println("찾을 수 없습니다.");

}

do{  

//만일 VARCHAR, CHAR ---> getString()

//만일 INT, INTEGER, NUMBER --> getInt()

//만일 REAL, NUMERIC, NUMBER(10,2) --> getDouble()

//만일 DATE, DATETIME --> getDate()

//getString(1) <-- 필드인덱스는 실제 테이블의 순서와 아무 상관이 없고,

//SELECT 1, 2, 3, 4, 5 -> SELECT 문장에서의 순서, 반드시 1부터 시작함.

String zipcode = rs.getString(1) ;

String sido = rs.getString("sido");

String gugun = rs.getString("gugun");

String dong = rs.getString(4);

String bunji = rs.getString(5);   if(bunji == null) bunji = "";

System.out.printf("(%s) %s %s %s %s\n", 

                       zipcode, sido, gugun, dong, bunji);

}while(rs.next());

}catch(SQLException ex){

ex.printStackTrace();

}

//7. Close 및 자원반납

try{

if(rs != null) rs.close();

if(stmt != null) stmt.close();

if(conn != null) conn.close();

}catch(SQLException ex){}

}

}

import java.sql.Connection;

import java.sql.PreparedStatement;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.util.Scanner;

public class JdbcDemo1 {

public static void main(String[] args) {

DBConnection db = new DBConnection();

db.loadDriver();

db.setConnection();

Connection conn = db.getConnection();

Scanner scan = new Scanner(System.in);

System.out.print("찾고자 하시는 동이름 : ");

String dongName = scan.nextLine();

//scan.nextLine();  //enter 날리자.

//Statement stmt = null;  

PreparedStatement pstmt = null;

String sql= "SELECT zipcode, sido, gugun, dong, bunji " + 

                  "FROM zipcode " + 

          "WHERE dong = ?";

ResultSet rs = null;

try{

pstmt = conn.prepareStatement(sql); //step 4.

pstmt.setString(1, dongName);    //---> 완전한 SQL 문장 형성

rs = pstmt.executeQuery();

if(!rs.next()){

System.out.println("찾을 수 없습니다.");  return;

}

do{  

String zipcode = rs.getString(1) ;

String sido = rs.getString("sido");

String gugun = rs.getString("gugun");

String dong = rs.getString(4);

String bunji = rs.getString(5);   if(bunji == null) bunji = "";

System.out.printf("(%s) %s %s %s %s\n", 

                       zipcode, sido, gugun, dong, bunji);

}while(rs.next());

rs.close();

pstmt.close();

}catch(SQLException ex){

ex.printStackTrace();

}

DBClose.close(conn);

}

}

import java.io.FileInputStream;

import java.io.FileNotFoundException;

import java.io.IOException;

import java.sql.Connection;

import java.util.Properties;

public class DBConnection{

private Properties info = null;

private Connection conn = null;

public DBConnection(){

info = new Properties();

try{

info.load(new FileInputStream("dbinfo.properties"));

}catch(FileNotFoundException ex){ ex.printStackTrace(); 

}catch(IOException ex){ ex.printStackTrace(); }

}

public void loadDriver(){

try{

Class.forName(info.getProperty("DBDRIVER"));

}catch(ClassNotFoundException ex){

System.out.println("Class Not Found");

}

}

public void setConnection(){

String url = info.getProperty("DBURL");

String user = info.getProperty("DBUSER");

String password = info.getProperty("DBPWD");

try{

conn = java.sql.DriverManager.getConnection(url, user, password);

}catch(java.sql.SQLException ex){

System.out.println("Cannot Connect Access");

}

}

public Connection getConnection(){

if(this.conn != null) return this.conn;

else return null;

}

}

import java.sql.Connection;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.sql.Statement;

public class DBClose {

public static void close(Connection conn){

try{

if(conn != null) conn.close();

}catch(SQLException ex){

ex.printStackTrace();

}

}

public static void close(Connection conn, Statement stmt){

try{

if(stmt != null) stmt.close();

if(conn != null) conn.close();

}catch(SQLException ex){

ex.printStackTrace();

}

}

public static void close(Connection conn, Statement stmt, ResultSet rs){

try{

if(rs != null) rs.close();

if(stmt != null) stmt.close();

if(conn != null) conn.close();

}catch(SQLException ex){

ex.printStackTrace();

}

}

}

결론 무엇을 배웠을까

SQLite

http://www.sqlite.org/ 접속. Download 탭에가서, 윈도우즈 용인 Precompiled Binaries for Windows 에서 sqlite-shell-win32-x86-3080403.zip(289.42 KiB)  다운.

압축풀고, C:에 SqliteRoom을 만들고 압축푼, sqlite3.exe를 넣음.

커맨드창에가서 SqliteRoom으로 이동해서 sqlite3 하면 sqlite가 실행됨.   .quit하면 종료.

sqlite3 test.db 입력하면 아직 test.db가 만들어진게 아니라, 테이블을 하나만들면 test.db가 만들어짐.

어제와 같은 것을 만들어보면

CREATE TABLE helloworld 엔터

(

id integer primary key,

pwd varchar(20) NOT NULL

);

을 입력한다.

.schema helloworld 를 입력하면 방금 입력한 소스를 다보여준다.

INSERT INTO helloworld VALUES(1, '1234');

INSERT INTO helloworld(pwd) VALUES('3333');

INSERT INTO helloworld(pwd) VALUES('P@$$WOrd'); 

//아이디는 자동으로 1씩 증가하기 때문에 주지않아도된다.

.show를 치면 현재 sqlite의 세팅된 환경설정을 보여준다.

.mode column 을 쳐서 모드를 바꾸고

.headers on  을 쳐서 세팅바꾸면.

그리고 select * from helloworld; 를 치면 보기 편하게 바뀐것을 볼 수 있다.

.quit로 빠져나온다.

구글에서 sqlite database browser 를 쳐서 가장 위에 사이트에 들어가서 녹색 다운로드 버튼 클릭.

다운받은 것을 알집을 풀고 폴더의 이름을 Sqlite Database Browser 로 이름을 바꾼다. 폴더를 C:\ProgramFiles 에 넣는다.

그리고 SQLite Database Browser 를 실행시키고 아까 만든 test.db를 오픈하면 내용을 볼 수 있음. 장점은 커맨드명령을 싫어한는 사람을 위한.

이클립스 sql explorer - new profile 에가서 설정.

구글에서 sqlite jdbc driver 검색. 제일 위 사이트 클릭. downloads 탭 선택. sqlite-jdbc4-3.8.2-SNAPSHOT.jar 다운.

받은 jar파일을 C:\SqliteRoom 에 넣어줌. 그리고 add/edit 들어가서 sqlite-edit 눌러서 방금 jar파일을 add jars해서 추가해주고 리스트드라이버 잡아주고 

URL을 jdbc:sqlite:C:/sqliteroom/test.db로 바꿔줌. ok해서 Name을 Sqlite3해주고 User~~~체크, Auto Commit 체크 ~~ ok.

연결시켜주고 select * from helloworld; 하면 안되네.-> 오른쪽에 Tables에 helloworld 눌러서 다시 해주면 된다.

다시 sql editor 창에서 

CREATE TABLE telephone

(

  telnum CHAR(8) PRIMARY KEY,

  gubun INTEGER NOT NULL,

  irum VARCHAR(20) NOT NULL,

  howmany INTEGER NOT NULL,

  gibon INTEGER,

  fee INTEGER,

  tax INTEGER,

  total INTEGER

);

run 하고 오른쪽에 Tables를 refresh하면 telephone table이 들어온 것을 볼 수 있다.

이클립스의 전화요금 관리프로그램의 우측버튼 built path-configuration build path 들어가서libraries 탭에서 add External JARs에서 sqliteroom의 jar파일을 선택해준다.

main에서 

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.SQLException;

import java.sql.Statement;

import java.util.Scanner;

public class Main {

public static void main(String[] args) {

//2. Driver Loading

try {

Class.forName("org.sqlite.JDBC");

System.out.println("Loading Success");

} catch (ClassNotFoundException e) {

System.out.println("Class Not Found");

}

//3. Connection

Connection conn = null;

String str = "jdbc:sqlite:C:/sqliteroom/test.db";

try{

conn = DriverManager.getConnection(str);

System.out.println("Connection Success");

}catch(SQLException ex){

System.out.println("Connection failure");

}

}

}

이렇게 해서 실행 시켜주어 connection 까지 완료한다.

dbinf.properties를 프로젝트에 넣어주고 내용을

DBDRIVER=org.sqlite.JDBC

DBURL=jdbc:sqlite:C:/SqliteRoom/test.db

로 바꿔줌.

다시 main을 

import java.sql.SQLException;

import java.sql.Statement;

import java.util.Scanner;

public class Main {

public static void main(String[] args) {

System.out.println("<<전화요금관리프로그램>>");

Scanner scan = new Scanner(System.in);

Main main = new Main();

int choice = 0;

while(true){

choice = main.showMenu(scan);

if(choice == 4) break;

switch(choice){

case 1 : Input input = new Input(scan);  input.input(); break; 

case 2 : Output output = new Output(); break;

case 3 : Search search = new Search(scan); search.search(); break;

}

}

System.out.println("Program is over...");

}

int showMenu(Scanner scan){

System.out.println("1:입력, 2:출력, 3:검색, 4:종료");

System.out.print(">> ");

return scan.nextInt();

}

}

이렇게 바꿔주고, 

DBConnection도

import java.io.FileInputStream;

import java.io.FileNotFoundException;

import java.io.IOException;

import java.sql.Connection;

import java.util.Properties;

public class DBConnection{

private Properties info = null;

private Connection conn = null;

public DBConnection(){

info = new Properties();

try{

info.load(new FileInputStream("dbinfo.properties"));

}catch(FileNotFoundException ex){ ex.printStackTrace(); 

}catch(IOException ex){ ex.printStackTrace(); }

}

public void loadDriver(){

try{

Class.forName(info.getProperty("DBDRIVER"));

}catch(ClassNotFoundException ex){

System.out.println("Class Not Found");

}

}

public void setConnection(){

String url = info.getProperty("DBURL");

try{

conn = java.sql.DriverManager.getConnection(url);

}catch(java.sql.SQLException ex){

System.out.println("Cannot Connect Access");

}

}

public Connection getConnection(){

if(this.conn != null) return this.conn;

else return null;

}

}

이렇게 바꿔줌(바꿔준건 dbinf.properties의 경로밖에없음. 그냥 자바프로젝트에 넣어주어서)

실행하면 잘됨. 몇명 입력하고 Sqlite Database Browser로 확인하면 입력된 것을 볼 수 있다.

전화요금관리프로그램에서 delete만 추가된 버전을 만들면(수정한 것만 적음)

import java.sql.SQLException;

import java.sql.Statement;

import java.util.Scanner;

public class Main {

public static void main(String[] args) {

/* //2. Driver Loading

try {

Class.forName("org.sqlite.JDBC");

System.out.println("Loading Success");

} catch (ClassNotFoundException e) {

System.out.println("Class Not Found");

}

//3. Connection

Connection conn = null;

String str = "jdbc:sqlite:C:/sqliteroom/test.db";

try{

conn = DriverManager.getConnection(str);

System.out.println("Connection Success");

}catch(SQLException ex){

System.out.println("Connection failure");

}

//4. Statement 객체 생성

Statement stmt = null;

try{

stmt = conn.createStatement();

//5. Query 실행

StringBuffer sb = new StringBuffer();

sb.append("CREATE TABLE telephone(");

sb.append("telnum    CHAR(8)  PRIMARY KEY, ");

sb.append("gubun   INTEGER   NOT NULL,");

sb.append("irum    VARCHAR(20)  NOT NULL,");

sb.append("howmany   INTEGER   NOT NULL,");

sb.append("gibon   INTEGER,");

sb.append("fee   INTEGER, ");

sb.append("tax   INTEGER, ");

sb.append("total  INTEGER)");

stmt.executeUpdate(sb.toString());

System.out.println("Table Creation Success");

}catch(SQLException ex){

ex.printStackTrace();

}

try{

if(stmt != null) stmt.close();

if(conn != null) conn.close();

}catch(SQLException ex){

ex.printStackTrace();

}*/

System.out.println("<<전화요금관리프로그램>>");

Scanner scan = new Scanner(System.in);

Main main = new Main();

int choice = 0;

while(true){

choice = main.showMenu(scan);

if(choice == 6) break;

switch(choice){

case 1 : Input input = new Input(scan);  input.input(); break; 

case 2 : Output output = new Output(); break;

case 3 : Search search = new Search(scan); search.search(); break;

case 4 : Delete delete = new Delete(scan); delete.delete(); break; 

//case 5 :

}

}

System.out.println("Program is over...");

}

int showMenu(Scanner scan){

System.out.println("1:입력, 2:출력, 3:검색, 4:삭제, 5:수정, 6:종료");

System.out.print(">> ");

return scan.nextInt();

}

}

import java.util.Scanner;

import java.util.Vector;

public class Delete {

private Scanner scan;

Delete(Scanner scan){

this.scan = scan;

}

void delete(){

System.out.print("1.이름으로 삭제,  2. 전화번호로 삭제 : ");

int choice = this.scan.nextInt();

this.scan.nextLine();

String sql = null;

if(choice == 1){  //이름으로 삭제

System.out.print("이름 : ");

String name = scan.nextLine();

sql = "DELETE FROM telephone WHERE irum = '" + name + "'";

}else if(choice == 2){   //전화번호로 삭제

System.out.print("전화번호 : ");

String telnum = scan.nextLine();

sql = "DELETE FROM telephone WHERE telnum = '" + telnum + "'";

}

CustomerController.delete(sql);

}

}

import java.sql.Connection;

import java.util.Vector;

public class CustomerController {

public static void delete(String sql){

DBConnection db = new DBConnection();

db.loadDriver();

db.setConnection();

Connection conn = db.getConnection();

CustomerDAO.delete(conn, sql);

DBClose.close(conn);

}

public static Vector<CustomerVO> search(String sql){

DBConnection db = new DBConnection();

db.loadDriver();

db.setConnection();

Connection conn = db.getConnection();

Vector<CustomerVO> vector = CustomerDAO.search(conn, sql);

DBClose.close(conn);

return vector;

}

public static void insert(CustomerVO c){

DBConnection db = new DBConnection();

db.loadDriver();

db.setConnection();

Connection conn = db.getConnection();

CustomerDAO.insert(conn, c);

DBClose.close(conn);

}

public static Vector<CustomerVO> select(){

DBConnection db = new DBConnection();

db.loadDriver();

db.setConnection();

Connection conn = db.getConnection();

Vector<CustomerVO> vector = CustomerDAO.select(conn);

DBClose.close(conn);

return vector;

}

}

import java.sql.Connection;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.sql.Statement;

import java.util.Vector;

public class CustomerDAO {

public static void delete(Connection conn, String sql){

Statement stmt = null;

try {

stmt = conn.createStatement();

stmt.executeUpdate(sql);

System.out.println("Delete Success");

stmt.close();

} catch (SQLException e) {

e.printStackTrace();

}

}

public static Vector<CustomerVO> search(Connection conn, String sql){

Vector<CustomerVO> vector = null;

Statement stmt = null;

ResultSet rs = null;

try{

stmt = conn.createStatement();

rs = stmt.executeQuery(sql);

if(rs.next()){ //있다면

vector = new Vector<CustomerVO>(1,1); //동명이인이 있을 수도있어 (1) 대신 (1,1)

do{

CustomerVO c = new CustomerVO();

c.setGubun(rs.getInt("gubun"));

c.setTelnum(rs.getString("telnum"));

c.setIrum(rs.getString("irum"));

c.setGibon(rs.getInt("gibon"));

c.setFee(rs.getInt("fee"));

c.setTax(rs.getInt("tax"));

c.setTotal(rs.getInt("total"));

vector.addElement(c);

}while(rs.next());

}

rs.close();

stmt.close();

}catch(SQLException ex){

ex.printStackTrace();

}

return vector;

}

public static Vector<CustomerVO> select(Connection conn){

Statement stmt = null;

ResultSet rs = null;

Vector<CustomerVO> vector = new Vector<CustomerVO>(1,1);

try {

stmt = conn.createStatement();

String sql = "SELECT * FROM Telephone";

rs = stmt.executeQuery(sql);

while(rs.next()){

CustomerVO c = new CustomerVO();

c.setGubun(rs.getInt("gubun"));

c.setTelnum(rs.getString("telnum"));

c.setIrum(rs.getString("irum"));

c.setGibon(rs.getInt("gibon"));

c.setFee(rs.getInt("fee"));

c.setTax(rs.getInt("tax"));

c.setTotal(rs.getInt("total"));

vector.addElement(c);

}

rs.close();

stmt.close();

} catch (SQLException e) {

e.printStackTrace();

}

return vector;

}

public static void insert(Connection conn, CustomerVO c){

Statement stmt = null;

try {

stmt = conn.createStatement();

StringBuffer sb = new StringBuffer("INSERT INTO Telephone ");

sb.append("VALUES('" + c.getTelnum() + "'," + c.getGubun());

sb.append(",'" + c.getIrum() + "'," + c.getHowmany());

sb.append("," + c.getGibon() + "," + c.getFee() + "," + c.getTax());

sb.append("," + c.getTotal() + ")");

//System.out.println(sb.toString());

stmt.executeUpdate(sb.toString());

stmt.close();

} catch (SQLException e) {

e.printStackTrace();

}

}

}

ㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡ

리눅스에서 sqlite3설치.

버츄얼 우분투를 켜서 sudo apt-get update 캐시업데이트.

sudo apt-get install sqlite3 libsqlite3-dev 해서 설치.

mkdir SqliteRoom으로 폴더하나 만들어주고 SqliteRoom 폴더안으로 들어가서  sqlite3 test.db 를 하면 테이블을 입력하면 test.db가 만들어질 것이다.

SQLite 끝.

=========================================================================

Server

1. Machine 이 서버.

2. OS 가 서버.

3. Program 이 서버

4. Server Service Start

ㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡ

MYSQL 시작.

윈도우즈에서  http://www.mysql.com/ 접속.

Download 탭에서 MySQL Community Edition의 다운로드로 이동.

MySQL Community Server (GPL) 선택.

밑에 쪽의 Windows(x86,64-bit), MySQL INstaller MSI 다운로드 선택.

Windows (x86, 32-bit), MSI Installer 5.6.17 234.7M 다운로드. 누르면 로그인 사인업 등이 잇는데 밑에 no thanks 클릭하면 다운로드됨.

다시  MySQL Community Edition의 다운로드로 이동 해서 

MySQL Workbench (GPL) 다운로드 선택 후 Windows (x86, 32-bit), MSI Installer 6.1.4 30.0M 다운로드 클릭. no thanks까지

다시 전으로 가서 MySQL Connectors 선택하고 Connector/J 선택. Windows (x86, 32-bit), MSI Installer 5.1.30 6.1M 다운로드. no thanks까지

http://www.sqlgate.com/ 접속. Download 탭이동. 

SQLGate for MySQL Developer 3.3.1.0 04/01/2014 11.7 M   다운로드.

그리고 다운받은 mysql-installer-community-5.6.17.0.msi 를 설치.

Install누르고 next, skip후 next 선택. Developer Default 선택. 나머지는 안건드리고 next.  그리고 기본설정대로 하고 execute.

동의하고 계속 install. 다 되면 next. 그리고 execute(보면 connector/j와 mysql Workbench 가 들어있는 것을 볼 수 있다. 괜히 깔았넹)

next, next, port number가 3306번인데 아래 파이어월을 열어준다에 체크가되어있다. 마지막에 show advanced option 체크 next.

MySQL Root Password 는 javamysql 을 해줌. next.

Windows Service Name은 두고 Start the MySQL Server at System Startup 체크 해제. next. 바로 next. next. next.

star MySQL Workbench after Setup 체크해제. finish.

실행시키는 첫번째 방법은 관리자권한으로 도스창열어줌. net start mysql56 시작. net stop mysql56 스탑.

두번째는 제어판에가서 관리도구가서 services 에서 MySQL56을 start or stop. 더블클릭해서 들어가면 Startup type에 Manual로 바꿔줌(부팅할때 자동으로 안올라오게 하기위해)

환경변수설정창에서 Path를 보면 MySQL이 올라온것을 볼 수 있다. 

그리고 환경변수 설정창에서 Systme variables에서 new를 선택.

name = MYSQL_HOME, values = C:\Program Files\MySQL\MySQL Server 5.6 로 설정.

그리고 Path에서 마지막에 %MYSQL_HOME%\bin 를 추가해줌.

일반 커맨드창을 열어서 set path해서 설정해줌.

그리고 mysql -h localhost -u root -p 하고 비번 javamysql 치면 mysql로 접속됨.

show databases; 를치면 기본적으로 설치된 데이터베이스를 볼 수 있다.

use world 를 치면 데이터베이스가 바뀐다.

show tables;

desc city;

use test

show tables;

DESC mysql.user;

select host, user, password from mysql.user;  //아무리 관리자라도 패스워드는 볼 수 없음.

exit   //종료

MySQL Workbench 실행.

local instance를 누르고 비번 javamysql을 누르면 들어가짐.

다시 관리자 명령프롬프트 접속. mysql -u root -p 엔터 비번쓰고

use mysql 엔터

GRANT ALL PRIVILEGES ON *.* TO 'root'@'%' IDENTIFIED BY 'javamysql';    @뒤는 클라이언트 머신을 얘기하는거임.

flush privileges; 엔터

위와 같이 설정하면  MySQL Workbench에서 Database 탭에서 connect to database 해서 다른 컴퓨터에 접근가능.(안되면 처음 홈화면에서 +해서 접속하면 됨)

명령프롬프트에서 접속할 때는 mysql -h 아이피or컴퓨터이름 -u root -p 로 다른컴퓨터로 접속가능.

아까 받은 SQLGateforMySQLDev.exe  설치.

호스트 localhost, 사용자 root, 암호 javamysql, 암호저장체크, 데이터베이스 mysql(접근할데이터베이스), 문자집합 utf8, 날짜형식 default. 접속테스트 누르고 접속.

이클립스 접속 해서 sql explorer 에서 new profile 들어가서 add/edit driver에서 mysql drivers 을 edit해서

extra class path 에서 add  JARs를 C:\Program Files\MySQL\Connector J 5.1.29의 mysql-conn~~~~.jar파일 선택.

list driver눌러서 driver class name을 com.mysql.jdbc.Driver 선택.

Example URL은 jdbc:mysql://localhost:3306/test로 해줌.(자기것에 3306포트에 아무것도 없는 test를 지정) . ok. ok

Name은 MySQL 5.6 , Driver는 MySQL Driver

autoLogon선택해서 user는 root, password는 javamysql 하고 autocommit 하고 ok.

커넥트하고 

select * FROM world.City

where countrycode = 'KOR';

이렇게 해보던지, 아니면 우측 위에 test를 world로 바꿔서 검색을 하던지.

하면 결과값볼수 있고.

다시 전화요금관리프로그램으로 이동.

build Path-configuration buildPath에 들어가서 libraries 탭에서 external jars에서 C:\Program Files\MySQL\Connector J 5.1.29 에서  mysql-conn~~~~.jar파일 선택.

Main에서

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.SQLException;

import java.sql.Statement;

public class Main {

public static void main(String[] args) {

//2. Driver Loading

try {

Class.forName("com.mysql.jdbc.Driver");

System.out.println("Loading Success");

} catch (ClassNotFoundException e) {

System.out.println("Class Not Found");

}

//3. Connection

Connection conn = null;

String str = "jdbc:mysql://Win8-22:3306/test";  //내컴터이름과 포트번호

try{

conn = DriverManager.getConnection(str,"root","javamysql"); //아이디,비번 넣야함.

System.out.println("Connection Success");

}catch(SQLException ex){

System.out.println("Connection failure");

}

//4. Statement 객체 생성

Statement stmt = null;

try{

stmt = conn.createStatement();

//5. Query 실행

StringBuffer sb = new StringBuffer();

sb.append("CREATE TABLE telephone(");

sb.append("telnum    CHAR(8)  PRIMARY KEY, ");

sb.append("gubun   INTEGER   NOT NULL,");

sb.append("irum    VARCHAR(20)  NOT NULL,");

sb.append("howmany   INTEGER   NOT NULL,");

sb.append("gibon   INTEGER,");

sb.append("fee   INTEGER, ");

sb.append("tax   INTEGER, ");

sb.append("total  INTEGER)");

stmt.executeUpdate(sb.toString());

System.out.println("Table Creation Success");

}catch(SQLException ex){

ex.printStackTrace();

}

try{

if(stmt != null) stmt.close();

if(conn != null) conn.close();

}catch(SQLException ex){

ex.printStackTrace();

}

}

}

위와같이해서 로딩, 연결, 테이블까지 만들어줌.

그리고 dbinfo.properties 를

DBDRIVER=com.mysql.jdbc.Driver

DBURL=jdbc:mysql://localhost:3306/test

DBUSER=root

DBPWD=javamysql

이와 같이 변경해줌.

그리고 DBConnection은 user와 pwd를 다시 추가했으니 다시변경.

import java.io.FileInputStream;

import java.io.FileNotFoundException;

import java.io.IOException;

import java.sql.Connection;

import java.util.Properties;

public class DBConnection{

private Properties info = null;

private Connection conn = null;

public DBConnection(){

info = new Properties();

try{

info.load(new FileInputStream("dbinfo.properties"));

}catch(FileNotFoundException ex){ ex.printStackTrace(); 

}catch(IOException ex){ ex.printStackTrace(); }

}

public void loadDriver(){

try{

Class.forName(info.getProperty("DBDRIVER"));

}catch(ClassNotFoundException ex){

System.out.println("Class Not Found");

}

}

public void setConnection(){

String url = info.getProperty("DBURL");

String user = info.getProperty("DBUSER");

String pwd = info.getProperty("DBPWD");

try{

conn = java.sql.DriverManager.getConnection(url, user, pwd);

}catch(java.sql.SQLException ex){

System.out.println("Cannot Connect Access");

}

}

public Connection getConnection(){

if(this.conn != null) return this.conn;

else return null;

}

}

그리고 다시 실행해보면 실행이 잘된다.

----------------------------------------------------

ㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡ

http://db.apache.org/ 들어가서 subprojects-Dearby-Download 탭선택. 

10.10.1.1 (April 15, 2013 / SVN 1458268) 눌러서

other mirror.apache-kr.org 선택해서 db-derby-10.10.1.1-bin.zip  다운.

압축을 풀고 Apache Derby 로 폴더이름 변경. C:\Program Files에 폴더 붙여넣어줌.

환경변수를 설정하기 위해 환경변수설정창 가서 System variables-New를 넣어서 name에는 DERBY_HOME , value: C:\Program Files\Apache Derby  넣어줌.

그리고 Path에서 Edit 들어가서 마지막에 %DERBY_HOME%\bin; 을 넣어줌.

명령프롬프트 창에가서 set derby_home  해서 설정해줌. set path 로 설정 셋.

cd\ 해서 md derbyroom 을 쳐서 폴더를 하나 만들어줌.  cd derbyroom으로 폴더안으로 들어가서

ij치면 자바 더비를 사용할 수 있음.

거기서 connect 'jdbc:derby:mydb;create=true'; 를 쳐서 디비를 만들어줌.

그리고 CREATE TABLE helloworld 엔터

(

id integer primary key,

pwd varchar(20) NOT NULL

);

해서 테스트를 해보면.

INSERT INTO helloworld VALUES(1, '123456');

INSERT INTO helloworld VALUES(2, '1111');

INSERT INTO helloworld VALUES(3, 'P@$$WOrd'); 

를 입력해주고

SELECT * FROM helloworld; 를 쳐서 입력한 것을 확인.

exit;으로 종료.

이클립스에 들어가서 sql explorer 을 띄어 

new profile에서 driver 에서 add/exit 를  눌러서 Apache Derby-Network Server 선택해서 edit 눌러서

extra Class path 에서 add JARs에서 

C:\Program Files\Apache Derby\lib 에서 derby.jar 선택.

그리고 list Drivers를 눌러주고 Driver class Name을 제일밑에 org.~~~~.EmbeddedDriver 선택.

그리고 Example URL을 jdbc:derby:C:/derbyroom/mydb;create=true; 으로 고쳐줌.(내가 나에게 접속하고 이름은 mydb 로 주었기 때문에). 그리고 ok. ok.

Driver는 지금 설정한 Apache Derby ~~ 선택하고 name은 Derby 하고 user name is not ~~~~~~ 체크

AutoCommit 체크 해서 ok. 

그리고 SELECT * FROM helloworld; 를 선택하면 아까 작성한 것을 볼 수 있다.

지난시간에 TelephoneMgmt를 Derby를 사용하여 해보자.

프로젝트 우측버튼 build path- configuration build path 눌러서 libraries 탭에서 Add External JARs를 눌러 C:\Program Files\Apache Derby\lib에서 derby.jar을 눌러줌.

그래야 Class.forName("org.apache.derby.jdbc.EmbeddedDriver"); 을 쓸수 있음.

dbinfo.properties을 아래처럼 변경.

DBDRIVER=org.apache.derby.jdbc.EmbeddedDriver

DBURL=jdbc:derby:c:/derbyroom/telephone;create=true

main을 아래와 같이 실행시켜주고 테이블을 디비에 만들어줌. 그리고 주석처리를 바꿔줌. 기존 주석처리 안된 것은 주석처리를, 주석처리 되어있는건 풀고.

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.SQLException;

import java.sql.Statement;

import java.util.Scanner;

public class Main {

public static void main(String[] args) {

//2. Driver Loading

try {

Class.forName("org.apache.derby.jdbc.EmbeddedDriver");

System.out.println("Loading Success");

} catch (ClassNotFoundException e) {

System.out.println("Class Not Found");

}

//3. Connection

Connection conn = null;

String str = "jdbc:derby:C:/derbyroom/telephone;create=true";

try{

conn = DriverManager.getConnection(str);

System.out.println("Connection Success");

}catch(SQLException ex){

System.out.println("Connection failure");

}

//4. Statement 객체 생성

Statement stmt = null;

try{

stmt = conn.createStatement();

//5. Query 실행

StringBuffer sb = new StringBuffer();

sb.append("CREATE TABLE telephone(");

sb.append("telnum    CHAR(8)  PRIMARY KEY, ");

sb.append("gubun   INTEGER   NOT NULL,");

sb.append("irum    VARCHAR(20)  NOT NULL,");

sb.append("howmany   INTEGER   NOT NULL,");

sb.append("gibon   INTEGER,");

sb.append("fee   INTEGER, ");

sb.append("tax   INTEGER, ");

sb.append("total  INTEGER)");

stmt.executeUpdate(sb.toString());

System.out.println("Table Creation Success");

}catch(SQLException ex){

ex.printStackTrace();

}

try{

if(stmt != null) stmt.close();

if(conn != null) conn.close();

}catch(SQLException ex){

ex.printStackTrace();

}

/*System.out.println("<<전화요금관리프로그램>>");

Scanner scan = new Scanner(System.in);

Main main = new Main();

int choice = 0;

while(true){

choice = main.showMenu(scan);

if(choice == 4) break;

switch(choice){

case 1 : Input input = new Input(scan);  input.input(); break; 

case 2 : Output output = new Output(); break;

//case 3 :

}

}

System.out.println("Program is over...");*/

}

int showMenu(Scanner scan){

System.out.println("1:입력, 2:출력, 3:검색, 4:종료");

System.out.print(">> ");

return scan.nextInt();

}

}

DBConnection.java는 아래와 같이 바꿔줌.

import java.io.FileInputStream;

import java.io.FileNotFoundException;

import java.io.IOException;

import java.sql.Connection;

import java.util.Properties;

public class DBConnection{

private Properties info = null;

private Connection conn = null;

public DBConnection(){

info = new Properties();

try{

info.load(new FileInputStream("D:\\Downloads\\dbinfo.properties"));

}catch(FileNotFoundException ex){ ex.printStackTrace(); 

}catch(IOException ex){ ex.printStackTrace(); }

}

public void loadDriver(){

try{

Class.forName(info.getProperty("DBDRIVER"));

}catch(ClassNotFoundException ex){

System.out.println("Class Not Found");

}

}

public void setConnection(){

String url = info.getProperty("DBURL");

try{

conn = java.sql.DriverManager.getConnection(url);

}catch(java.sql.SQLException ex){

System.out.println("Cannot Connect Access");

}

}

public Connection getConnection(){

if(this.conn != null) return this.conn;

else return null;

}

}

바뀐건 userid, userpwd부분을 삭제한 것.

그리고 실행. 잘됨.

잘되는 것을 확인했으니 지난번에 못한 검색을 추가하는 버전을 만들면.

전화요금관리프로그램 

public class CustomerVO {

private int gubun;

private String telnum;

private String irum;

private int howmany;

private int gibon;

private int fee;

private int tax;

private int total;

public CustomerVO(){}

public CustomerVO(int gubun, String telnum, String irum, int howmany) {

this.gubun = gubun;

this.telnum = telnum;

this.irum = irum;

this.howmany = howmany;

}

@Override

public String toString(){

return String.format("%d\t%s\t%s\t%,d\t%,d\t%,d\t%,d",

                   this.gubun, this.telnum, this.irum, this.gibon,

                   this.fee, this.tax, this.total);

}

public int getGubun() {

return gubun;

}

public void setGubun(int gubun) {

this.gubun = gubun;

}

public String getTelnum() {

return telnum;

}

public void setTelnum(String telnum) {

this.telnum = telnum;

}

public String getIrum() {

return irum;

}

public void setIrum(String irum) {

this.irum = irum;

}

public int getHowmany() {

return howmany;

}

public void setHowmany(int howmany) {

this.howmany = howmany;

}

public int getGibon() {

return gibon;

}

public void setGibon(int gibon) {

this.gibon = gibon;

}

public int getFee() {

return fee;

}

public void setFee(int fee) {

this.fee = fee;

}

public int getTax() {

return tax;

}

public void setTax(int tax) {

this.tax = tax;

}

public int getTotal() {

return total;

}

public void setTotal(int total) {

this.total = total;

}

}

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.SQLException;

import java.sql.Statement;

import java.util.Scanner;

public class Main {

public static void main(String[] args) {

/* //2. Driver Loading

try {

Class.forName("org.apache.derby.jdbc.EmbeddedDriver");

System.out.println("Loading Success");

} catch (ClassNotFoundException e) {

System.out.println("Class Not Found");

}

//3. Connection

Connection conn = null;

String str = "jdbc:derby:C:/derbyroom/telephone;create=true";

try{

conn = DriverManager.getConnection(str);

System.out.println("Connection Success");

}catch(SQLException ex){

System.out.println("Connection failure");

}

//4. Statement 객체 생성

Statement stmt = null;

try{

stmt = conn.createStatement();

//5. Query 실행

StringBuffer sb = new StringBuffer();

sb.append("CREATE TABLE telephone(");

sb.append("telnum    CHAR(8)  PRIMARY KEY, ");

sb.append("gubun   INTEGER   NOT NULL,");

sb.append("irum    VARCHAR(20)  NOT NULL,");

sb.append("howmany   INTEGER   NOT NULL,");

sb.append("gibon   INTEGER,");

sb.append("fee   INTEGER, ");

sb.append("tax   INTEGER, ");

sb.append("total  INTEGER)");

stmt.executeUpdate(sb.toString());

System.out.println("Table Creation Success");

}catch(SQLException ex){

ex.printStackTrace();

}

try{

if(stmt != null) stmt.close();

if(conn != null) conn.close();

}catch(SQLException ex){

ex.printStackTrace();

}*/

System.out.println("<<전화요금관리프로그램>>");

Scanner scan = new Scanner(System.in);

Main main = new Main();

int choice = 0;

while(true){

choice = main.showMenu(scan);

if(choice == 4) break;

switch(choice){

case 1 : Input input = new Input(scan);  input.input(); break; 

case 2 : Output output = new Output(); break;

case 3 : Search search = new Search(scan); search.search(); break;

}

}

System.out.println("Program is over...");

}

int showMenu(Scanner scan){

System.out.println("1:입력, 2:출력, 3:검색, 4:종료");

System.out.print(">> ");

return scan.nextInt();

}

}

import java.util.Scanner;

public class Input {

private Scanner scan;

Input(Scanner scan){

this.scan = scan;

}

void input(){

System.out.print("구분 : ");   int gubun = this.scan.nextInt();

System.out.print("전화번호 : "); String telnum = this.scan.next();

this.scan.nextLine();

System.out.print("성명 : "); String irum = this.scan.nextLine();

System.out.print("통화량 : ");  int howmany = this.scan.nextInt();

this.scan.nextLine();

CustomerVO c = new CustomerVO(gubun, telnum, irum, howmany);

Calc calc = new Calc(c);

CustomerController.insert(c);

}

}

import java.util.Scanner;

import java.util.Vector;

public class Search {

private Scanner scan;

Search(Scanner scan){

this.scan = scan;

}

void search(){

System.out.print("1.이름으로 검색,  2. 전화번호로 검색 : ");

int choice = this.scan.nextInt();

this.scan.nextLine();

String sql = null;

if(choice == 1){  //이름으로 검색

System.out.print("이름 : ");

String name = scan.nextLine();

sql = "SELECT * FROM telephone WHERE irum = '" + name + "' ";

}else if(choice == 2){   //전화번호로 검색

System.out.print("전화번호 : ");

String telnum = scan.nextLine();

sql = "SELECT * FROM telephone WHERE telnum = '" + telnum + "' ";

}

Vector<CustomerVO> vector = CustomerController.search(sql);

if(vector == null){

System.out.println("조건에 맞는 데이터가 없습니다.");

}

else{

for(int i = 0 ; i < vector.size() ; i++){

CustomerVO c = vector.get(i);

System.out.println(c);

}

}

}

}

public class Calc {

private CustomerVO c;

Calc(CustomerVO c){

this.c = c;

calc();

}

void calc(){

//1)입력되는 값이 구분이 1이면 영업용, 2이면 관청용, 3이면 가정용이다.

int gibon = (c.getGubun() == 1) ? 6000 :

                 (c.getGubun() == 2) ? 4800 : 3000;

//2)기본요금은 영업용이 6,000원, 관청용이 4,800원, 가정용이 3,000원이다.

//3)통화료는 1통화에 대하여 12원이다.

int fee = c.getHowmany() * 12;

//4)세금은 기본 요금과 통화료를 합한 금액의 10%를 부과한다.

int tax = (int)((gibon + fee) * 0.1);

int total = gibon + fee + tax;

c.setGibon(gibon);

c.setFee(fee);

c.setTax(tax);

c.setTotal(total);

}

}

import java.sql.Connection;

import java.util.Vector;

public class CustomerController {

public static Vector<CustomerVO> search(String sql){

DBConnection db = new DBConnection();

db.loadDriver();

db.setConnection();

Connection conn = db.getConnection();

Vector<CustomerVO> vector = CustomerDAO.search(conn, sql);

DBClose.close(conn);

return vector;

}

public static void insert(CustomerVO c){

DBConnection db = new DBConnection();

db.loadDriver();

db.setConnection();

Connection conn = db.getConnection();

CustomerDAO.insert(conn, c);

DBClose.close(conn);

}

public static Vector <CustomerVO> select(){

DBConnection db = new DBConnection();

db.loadDriver();

db.setConnection();

Connection conn = db.getConnection();

Vector<CustomerVO> vector = CustomerDAO.select(conn);

DBClose.close(conn);

return vector;

}

}

import java.sql.Connection;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.sql.Statement;

import java.util.Vector;

public class CustomerDAO {

public static Vector<CustomerVO> search(Connection conn, String sql){

Vector<CustomerVO> vector = null;

Statement stmt = null;

ResultSet rs = null;

try{

stmt = conn.createStatement();

rs = stmt.executeQuery(sql);

if(rs.next()){ //있다면

vector = new Vector<CustomerVO>(1,1); //동명이인이 있을 수도있어 (1) 대신 (1,1)

do{

CustomerVO c = new CustomerVO();

c.setGubun(rs.getInt("gubun"));

c.setTelnum(rs.getString("telnum"));

c.setIrum(rs.getString("irum"));

c.setGibon(rs.getInt("gibon"));

c.setFee(rs.getInt("fee"));

c.setTax(rs.getInt("tax"));

c.setTotal(rs.getInt("total"));

vector.addElement(c);

}while(rs.next());

}

rs.close();

stmt.close();

}catch(SQLException ex){

ex.printStackTrace();

}

return vector;

}

public static Vector<CustomerVO> select(Connection conn){

Statement stmt = null;

ResultSet rs = null;

Vector<CustomerVO> vector = new Vector<CustomerVO>(1,1);

try {

stmt = conn.createStatement();

String sql = "SELECT * FROM Telephone";

rs = stmt.executeQuery(sql);

while(rs.next()){

CustomerVO c = new CustomerVO();

c.setGubun(rs.getInt("gubun"));

c.setTelnum(rs.getString("telnum"));

c.setIrum(rs.getString("irum"));

c.setGibon(rs.getInt("gibon"));

c.setFee(rs.getInt("fee"));

c.setTax(rs.getInt("tax"));

c.setTotal(rs.getInt("total"));

vector.addElement(c);

}

rs.close();

stmt.close();

} catch (SQLException e) {

e.printStackTrace();

}

return vector;

}

public static void insert(Connection conn, CustomerVO c){

Statement stmt = null;

try {

stmt = conn.createStatement();

StringBuffer sb = new StringBuffer("INSERT INTO Telephone ");

sb.append("VALUES('" + c.getTelnum() + "'," + c.getGubun());

sb.append(",'" + c.getIrum() + "'," + c.getHowmany());

sb.append("," + c.getGibon() + "," + c.getFee() + "," + c.getTax());

sb.append("," + c.getTotal() + ")");

//System.out.println(sb.toString());

stmt.executeUpdate(sb.toString());

stmt.close();

} catch (SQLException e) {

e.printStackTrace();

}

}

}

import java.sql.Connection;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.sql.Statement;

public class DBClose {

public static void close(Connection conn){

try{

if(conn != null) conn.close();

}catch(SQLException ex){

ex.printStackTrace();

}

}

public static void close(Connection conn, Statement stmt){

try{

if(stmt != null) stmt.close();

if(conn != null) conn.close();

}catch(SQLException ex){

ex.printStackTrace();

}

}

public static void close(Connection conn, Statement stmt, ResultSet rs){

try{

if(rs != null) rs.close();

if(stmt != null) stmt.close();

if(conn != null) conn.close();

}catch(SQLException ex){

ex.printStackTrace();

}

}

}

import java.io.FileInputStream;

import java.io.FileNotFoundException;

import java.io.IOException;

import java.sql.Connection;

import java.util.Properties;

public class DBConnection{

private Properties info = null;

private Connection conn = null;

public DBConnection(){

info = new Properties();

try{

info.load(new FileInputStream("D:\\Downloads\\dbinfo.properties"));

}catch(FileNotFoundException ex){ ex.printStackTrace(); 

}catch(IOException ex){ ex.printStackTrace(); }

}

public void loadDriver(){

try{

Class.forName(info.getProperty("DBDRIVER"));

}catch(ClassNotFoundException ex){

System.out.println("Class Not Found");

}

}

public void setConnection(){

String url = info.getProperty("DBURL");

try{

conn = java.sql.DriverManager.getConnection(url);

}catch(java.sql.SQLException ex){

System.out.println("Cannot Connect Access");

}

}

public Connection getConnection(){

if(this.conn != null) return this.conn;

else return null;

}

}

import java.util.Vector;

public class Output {

Output(){

Vector<CustomerVO> vector = CustomerController.select();

for(int i = 0 ; i < vector.size() ; i++){

CustomerVO c = vector.get(i);

System.out.println(c);

}

}

}

ㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡ=====================================================================================================

리눅스에서 

리눅스에서도 http://db.apache.org/에 접속해서 derby-download에서 db-derby-10.10.1.1-src.tar.gz 다운.

압축을 푼후 폴더이름을 Derby 로 변경. 터미널 켜서 Derby 폴더가 있는 곳으로 가서 sudo mv Derby /usr/lib/jvm 로 폴더이동.

sudo gedit /etc/profile 로 들어가서.

예전에 자바세팅한 것을

#----------------------------------------------

# Java Settings

#----------------------------------------------

JAVA_HOME=/usr/lib/jvm/jdk1.7.0_51

DERBY_HOME=/usr/lib/jvm/Derby

CLASSPATH=.:/usr/lib/jvm/jdk1.7.0_51/lib/tools.jar

PATH=$JAVA_HOME/bin/:$PATH:$DERBY_HOME/bin

export JAVA_HOME

export DERBY_HOME

export CLASSPATH

export PATH

위와 같이 변경. 터미널에서 source /etc/profile 엔터.

echo $PATH으로 확인.

home으로 가서(/home/mino)  mkdir DerbyRoom 하나 만들어줌.

만들어준 폴더에 들어가서

ij

connect 'jdbc:derby:mydb;create=true';

CREATE TABLE helloworld

(

id integer primary key,

pwd varchar(20) not null);

INSERT INTO helloworld VALUES(1, '123456');

INSERT INTO helloworld VALUES(2, 'P@$$W0rd');

SELECT * FROM helloworld;

이클립스에 sql explorer 사용을 위해서.

구글에서 sql explorer 검색 해서 Eclipse SQL Explorer들어가서 download 들어가서 SQL Explorer Plugin 누르고  

3.6.1- sqlexplorer_plugin-3.6.1_SR6.zip 눌러서 다운. 압축풀고 이클립스폴더에 feature폴더 plugins 폴더에 각각 넣어줌.

이클립스를 다시켜서 sql explore를 열어서 new profile 에서 add/edit drivers 선택해서 apach derby 를 선택해 edit 해서  

add jars 해서  /usr/lib/jvm/Derby/lib/derby.jar 선택. list Drivers 누르고 

driver class name 을 org.~~~~.EmbeddedDriver 선택. example URL 을  jdbc:derby:/home/mino/DerbyRoom/mydb;create=true; 써줌.

ok누르고 Name은 Derby User name is~~~ 체크 auto commit 체크.

cd /usr/lib/jvm/Derby/lib 에 들어가서 chmod +x *.* 을 써서 실행 가능하게 함. 그리고 이 위치에서 java -jar derbyrun.jar server start  엔터를 하면  쭈르륵 뜬걸 볼 수 있다.(에러발생?)

gedit을 열어서 open 해서 /usr/lib/jvm/jdk_1.7.0_51/jre/lib/security/java.policy 를 열어줌. 

여기서 23번째 줄에서 localhost:1527로 바꿔줌.

그리고 위에 java -jar derbyrun.jar server start를 다시 써주면. started 된것을 볼 수 있다.

또 다른 확인 방법 하나- 터미널을 하나 더 켜서 netstat -ap | grep "LISTEN" 엔터.

기존것을 다 지우고 new profile 에서  add/edit 해서 extra class path에서 /usr/lib/jvm/Derby/lib/derbyclient.jar 해주고 

list Drivers 누르면 Driver Class Name 을 org.apache.derby.jdbc.ClientDriver를 선택.

URL은 jdbc:derby://localhost:1527/mydb;create=true; 해주고. Name은 NetworkDerby

아까 started 된 것은 계속 되고 있어야함. 

서버 종료는 cd /usr/lib/jvm/Derby/lib 이동해서

java -jar derbyrun.jar server shutdown  하면 서버를 종료할 수 있다.

우분투(클라이언트)에서 버츄얼우분투의 접속은

서버측에서 java -jar derbyrun.jar server start -h 자기아이피 해서 서버를 열고 

클라이언트에서 접속하면 성공. 그리고 서버측에서 /usr/lib/jvm/Derby/lib/mydb 가 있는 것을 볼 수있다.

(클라이언트 측에서는 jdbc:derby://서버아이피:1527/mydb;create=true; 

서버측에서는 위의 리눅스 시작부분부터 여기서 23번째 줄에서 localhost:1527로 바꿔줌.부분까지 설정. 하면됨)

ODBC 설정. Control Panel\All Control Panel Items\Administrative Tools\ODBC Data Sources 들어가서

System DSN 탭에서 Add눌러서 .mdb or .accdb 택하고 확인. data source name에 이름(난 school) 써주고(ODBC 이름), 데이터베이스 선택 을 눌러서 사용할 액세스파일(이미 만든 school)을 지정해줌.

advanced 누르면 아이디 비번을 정해줄 수 있다. 아디scott, 비번tiger  해줌.

그리고 이클립스에서 window- other perspective 에서 sql Explorer 선택.

new-connection profile에서 name은 아무거나, Driver는 jdbc odbc bridget 해주고 URL : jdbc:odbc:school(school은 아까정한 odbc이름). User는 scott, password는 tiger.

Auto Logon 과 Auto Commit 체크.

메모장을 열어 아래와 같이 적어서 저장해줌. dbinfo.properties 로 모든파일로 저장해서 d: downloads폴더에 저장.

DBDRIVER=sun.jdbc.odbc.JdbcOdbcDriver

DBURL=jdbc:odbc:school

DBUSER=scott

DBPWD=tiger

여기까진 설정.

3/27성적관리프로그램에서 디비추가(원본보기만활성화)

public class Student implements Comparable<Student> {

private String hakbun, name;

private int kor, eng, mat, edp, tot, ranking;

private double avg;

private char grade;

public Student(){}

public Student(String hakbun, String name, int kor, int eng, int mat, int edp) {

this.hakbun = hakbun;

this.name = name;

this.kor = kor;

this.eng = eng;

this.mat = mat;

this.edp = edp;

this.ranking = 1;

}

@Override

public int compareTo(Student s){

return this.getTot() - s.getTot();

}

public String [] toArray(){

String [] array = new String[10];

array[0] = this.hakbun;   array[1] = this.name;

array[2] = String.valueOf(this.kor);       array[3] = String.valueOf(this.eng);     

array[4] = String.valueOf(this.mat);       array[5] = String.valueOf(this.edp);     

array[6] = String.valueOf(this.tot);         array[7] = String.valueOf(this.avg);

array[8] = String.valueOf(this.grade);    array[9] = String.valueOf(this.ranking);          

return array;

}

@Override

public String toString(){

return String.format("%-10s%7s%5d%5d%5d%5d%5d%10.2f%5c%5d\n",

this.hakbun, this.name, this.kor, this.eng, this.mat, this.edp,

this.tot, this.avg, this.grade, this.ranking);

}

public String getHakbun() {

return hakbun;

}

public void setHakbun(String hakbun) {

this.hakbun = hakbun;

}

public String getName() {

return name;

}

public void setName(String name) {

this.name = name;

}

public int getKor() {

return kor;

}

public void setKor(int kor) {

this.kor = kor;

}

public int getEng() {

return eng;

}

public void setEng(int eng) {

this.eng = eng;

}

public int getMat() {

return mat;

}

public void setMat(int mat) {

this.mat = mat;

}

public int getEdp() {

return edp;

}

public void setEdp(int edp) {

this.edp = edp;

}

public int getTot() {

return tot;

}

public void setTot(int tot) {

this.tot = tot;

}

public int getRanking() {

return ranking;

}

public void setRanking(int ranking) {

this.ranking = ranking;

}

public double getAvg() {

return avg;

}

public void setAvg(double avg) {

this.avg = avg;

}

public char getGrade() {

return grade;

}

public void setGrade(char grade) {

this.grade = grade;

}

}

import java.awt.Container;

import java.sql.Connection;

import java.sql.ResultSet;

import java.sql.Statement;

import java.util.Vector;

import javax.swing.JFrame;

import javax.swing.JTabbedPane;

public class Main {

private JFrame f;

private JTabbedPane tab;

private Container con;

private Main(){

this.f = new JFrame("성적관리프로그램 V3.0");

this.tab = new JTabbedPane();

this.con = this.f.getContentPane();

}

private void display(){

this.f.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);

this.f.setResizable(false);

this.tab.addTab("일반데이터입력", new InputPanel(this.f, this.tab));

this.tab.addTab("데이터출력", new OutputPanel(this.f));

this.con.add(this.tab);

this.f.setSize(500, 400);

this.f.setLocationRelativeTo(null);

this.f.setVisible(true);

}

public static void main(String[] args) {

new Main().display();

}

}

import java.util.Vector;

public class Calc {

private Vector<Student> vector;

public Calc(Vector<Student> vector) {

this.vector = vector;

}

public void calc(){

for(int i = 0 ; i < this.vector.size() ; i++){

Student s = this.vector.get(i);

s.setTot(s.getKor() + s.getEng() + s.getMat() + s.getEdp());

s.setAvg(s.getTot() / 4.);

s.setGrade(this.getGrade(s.getAvg()));

}

}

private char getGrade(double avg){

if(avg <=100 && avg >= 90) return 'A';

else if(avg < 90 && avg >= 80) return 'B';

else if(avg < 80 && avg >= 70) return 'C';

else if(avg < 70 && avg >= 60) return 'D';

else return 'F';

}

}

import java.sql.Connection;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.sql.Statement;

public class DBClose {

public static void close(Connection conn){

try{

if(conn != null) conn.close();

}catch(SQLException ex){

ex.printStackTrace();

}

}

public static void close(Connection conn, Statement stmt){

try{

if(stmt != null) stmt.close();

if(conn != null) conn.close();

}catch(SQLException ex){

ex.printStackTrace();

}

}

public static void close(Connection conn, Statement stmt, ResultSet rs){

try{

if(rs != null) rs.close();

if(stmt != null) stmt.close();

if(conn != null) conn.close();

}catch(SQLException ex){

ex.printStackTrace();

}

}

}

import java.io.FileInputStream;

import java.io.FileNotFoundException;

import java.io.IOException;

import java.sql.Connection;

import java.util.Properties;

public class DBConnection{

private Properties info = null;

private Connection conn = null;

public DBConnection(){

info = new Properties();

try{

info.load(new FileInputStream("D:\\Downloads\\dbinfo.properties"));

}catch(FileNotFoundException ex){ ex.printStackTrace(); 

}catch(IOException ex){ ex.printStackTrace(); }

}

public void loadDriver(){

try{

Class.forName(info.getProperty("DBDRIVER"));

}catch(ClassNotFoundException ex){

System.out.println("Class Not Found");

}

}

public void setConnection(){

String url = info.getProperty("DBURL");

String user = info.getProperty("DBUSER");

String passwd = info.getProperty("DBPASSWORD");

try{

conn = java.sql.DriverManager.getConnection(url, user, passwd);

}catch(java.sql.SQLException ex){

System.out.println("Cannot Connect Access");

}

}

public Connection getConnection(){

if(this.conn != null) return this.conn;

else return null;

}

}

import java.awt.BorderLayout;

import java.awt.Font;

import java.awt.GridLayout;

import java.util.Vector;

import javax.swing.JButton;

import javax.swing.JFrame;

import javax.swing.JLabel;

import javax.swing.JPanel;

import javax.swing.JTabbedPane;

import javax.swing.JTextField;

import javax.swing.border.TitledBorder;

public class InputPanel extends JPanel {

private JFrame f;

private JLabel lblHakbun, lblName, lblKor,lblEng, lblMat, lblEdp;

private JTextField tfHakbun, tfName, tfKor, tfEng, tfMat, tfEdp;

private JButton btnContinue, btnBreak;

private Font font;

private JTabbedPane tab;

public InputPanel(JFrame f, JTabbedPane tab) {

this.f = f;

this.tab = tab;

this.font = new Font("NanumGotic", Font.PLAIN, 20);

this.setLayout(new BorderLayout());

this.add("Center", getCenter());

this.add("South", getSouth());

}

private JPanel getSouth(){

JPanel p = new JPanel();

p.add(this.btnContinue = new JButton("입력하기"));

this.btnContinue.setFont(font);

this.btnContinue.addActionListener(

new InputAction(this.f, this.tab, this.tfHakbun, tfName, 

                     this.tfKor, this.tfEng, this.tfMat, this.tfEdp));

p.add(this.btnBreak = new JButton("출력하기"));

this.btnBreak.setFont(font);

this.btnBreak.addActionListener(

new InputAction(this.f, this.tab, this.tfHakbun, tfName, 

                     this.tfKor, this.tfEng,this.tfMat, this.tfEdp));

return p;

}

private JPanel getCenter(){

JPanel p, inner;

inner = new JPanel();

inner.setBorder(new TitledBorder("성적데이터입력"));

inner.setLayout(new GridLayout(6,2,10,10));

inner.add(this.lblHakbun = new JLabel("학번"));

this.lblHakbun.setFont(font);

inner.add(this.tfHakbun = new JTextField(10));

this.tfHakbun.setFont(font);

inner.add(this.lblName = new JLabel("이름"));

this.lblName.setFont(font);

inner.add(this.tfName = new JTextField());

this.tfName.setFont(font);

inner.add(this.lblKor = new JLabel("국어"));

this.lblKor.setFont(font);

inner.add(this.tfKor = new JTextField());

this.tfKor.setFont(font);

inner.add(this.lblEng = new JLabel("영어"));

this.lblEng.setFont(font);

inner.add(this.tfEng = new JTextField());

this.tfEng.setFont(font);

inner.add(this.lblMat = new JLabel("수학"));

this.lblMat.setFont(font);

inner.add(this.tfMat = new JTextField());

this.tfMat.setFont(font);

inner.add(this.lblEdp = new JLabel("전산"));

this.lblEdp.setFont(font);

inner.add(this.tfEdp = new JTextField());

this.tfEdp.setFont(font);

p = new JPanel();

p.add(inner);

return p;

}

}

import java.awt.event.ActionEvent;

import java.awt.event.ActionListener;

import java.util.Vector;

import javax.swing.JFrame;

import javax.swing.JOptionPane;

import javax.swing.JTabbedPane;

import javax.swing.JTextField;

public class InputAction implements ActionListener {

private JFrame f;

private JTabbedPane tab;

private JTextField tfHakbun, tfName, tfKor, tfEng, tfMat, tfEdp;

public InputAction(JFrame f, JTabbedPane tab,

JTextField tfHakbun, JTextField tfName, JTextField tfKor,

JTextField tfEng, JTextField tfMat, JTextField tfEdp) {

this.f = f;

this.tab = tab;

this.tfHakbun = tfHakbun;

this.tfName = tfName;

this.tfKor = tfKor;

this.tfEng = tfEng;

this.tfMat = tfMat;

this.tfEdp = tfEdp;

}

@Override

public void actionPerformed(ActionEvent e) {

if(e.getActionCommand().equals("입력하기")){

if(!this.check()){

JOptionPane.showMessageDialog(this.f, "입력되지 않은 데이터가 있습니다.", 

"Warning", JOptionPane.WARNING_MESSAGE);

this.tfHakbun.requestFocus();

}else{  //모두 입력했다면

Student s = new Student(this.tfHakbun.getText().trim(), 

                                this.tfName.getText().trim(),

                                Integer.parseInt(this.tfKor.getText().trim()),

                                Integer.parseInt(this.tfEng.getText().trim()),

                                Integer.parseInt(this.tfMat.getText().trim()),

                                Integer.parseInt(this.tfEdp.getText().trim()));

StudentController.insert(s);

JOptionPane.showMessageDialog(this.f, "입력됐습니다.", 

"Success", JOptionPane.INFORMATION_MESSAGE);

this.tfHakbun.setText("");  this.tfName.setText("");

this.tfKor.setText("");  this.tfEng.setText("");

this.tfMat.setText("");  this.tfEdp.setText("");

}

}else if(e.getActionCommand().equals("출력하기")){

this.tab.setSelectedIndex(1);

}

}

private boolean check(){

if(this.tfHakbun.getText().length() == 0 || 

this.tfName.getText().length() == 0 ||

this.tfKor.getText().length() == 0 ||

this.tfEng.getText().length() == 0 ||

this.tfMat.getText().length() == 0 ||

this.tfEdp.getText().length() == 0) return false;

else return true;

}

}

import java.util.Vector;

public class Output {

private Vector<Student> vector;

public Output(Vector<Student> vector) {

this.vector = vector;

}

public void output(){

printLabel();

for(int i = 0 ; i < this.vector.size() ; i++)

System.out.print(this.vector.elementAt(i));

}

private void printLabel(){

System.out.println("                      <<�깆쟻愿�━�꾨줈洹몃옩>>");

}

}

import java.awt.BorderLayout;

import java.util.Vector;

import javax.swing.JButton;

import javax.swing.JFrame;

import javax.swing.JPanel;

import javax.swing.JScrollPane;

import javax.swing.JTable;

import javax.swing.ListSelectionModel;

public class OutputPanel extends JPanel{

private JFrame f;

private JScrollPane pane;

private JTable table;

private JButton btnOriginal, btnCalc, btnSort, btnDelete;

private JPanel p;

OutputPanel(JFrame f) {

this.f = f;

this.p = new JPanel();

this.table = new JTable();

//this.table.setSelectionMode(ListSelectionModel.SINGLE_SELECTION);

this.btnOriginal = new JButton("원본보기");

this.btnOriginal.addActionListener(new OutputAction(this.f, this.table));

this.btnCalc = new JButton("계산하기");

this.btnCalc.addActionListener(new OutputAction(this.f, this.table));

this.btnSort = new JButton("정렬하기");

this.btnSort.addActionListener(new OutputAction(this.f, this.table));

this.btnDelete = new JButton("삭제하기");

this.btnDelete.addActionListener(new OutputAction(this.f, this.table));

pane = new JScrollPane(this.table, 

JScrollPane.VERTICAL_SCROLLBAR_ALWAYS,

JScrollPane.HORIZONTAL_SCROLLBAR_ALWAYS);

this.setLayout(new BorderLayout());

this.add("Center", pane);

this.p.add(this.btnOriginal);  this.p.add(this.btnCalc);  this.p.add(this.btnSort);  

this.p.add(this.btnDelete);

this.add("North", p);

}

}

import java.awt.event.ActionEvent;

import java.awt.event.ActionListener;

import java.util.Vector;

import javax.swing.JFrame;

import javax.swing.JOptionPane;

import javax.swing.JTable;

public class OutputAction implements ActionListener {

private JFrame f;

private JTable table;

OutputAction(JFrame f, JTable table){

this.f = f;

this.table = table;

}

@Override

public void actionPerformed(ActionEvent e) {

switch(e.getActionCommand()){

case "원본보기": viewOriginal(); break;

//case "계산하기": calc(); break;

//case "정렬하기": sort(); break;

//case "삭제하기": delete(); break;

}

}

/*private void delete() {

int [] array = this.table.getSelectedRows();  //1,3,5

for(int i = array.length - 1 ; i >= 0 ; i--){

this.vector.removeElementAt(array[i]);

}

this.sort();

}*/

private void viewOriginal(){  //원본보기

this.table.setModel(new StudentModel(6));

}

/*private void calc(){

Calc calc = new Calc(this.vector);

calc.calc();

this.table.setModel(new StudentModel(this.vector, 9));

}*/

/*private void sort(){

Sort sort = new Sort(this.vector);

sort.sort();

this.table.setModel(new StudentModel(this.vector, 10));

}*/

}

import java.util.Vector;

public class Sort {

private Vector<Student> vector;

public Sort(Vector<Student> vector) {

this.vector = vector;

for(int i = 0 ; i < this.vector.size() ; i++)

this.vector.get(i).setRanking(1);

}

public void sort(){   //��궧���꾪븳 �좏깮�뺣젹

for(int i = 0 ; i < this.vector.size() - 1 ; i++){

for(int j = i +1 ; j < this.vector.size() ; j++){

if(this.vector.get(i).compareTo(this.vector.get(j)) > 0){

this.vector.get(j).setRanking(this.vector.get(j).getRanking() + 1);

}else if(this.vector.get(i).compareTo(this.vector.get(j)) < 0){

this.vector.get(i).setRanking(this.vector.get(i).getRanking() +1);

}

}

}

}

}

import java.sql.Connection;

import java.util.Vector;

public class StudentController {

public static void insert(Student s) {

DBConnection conn = new DBConnection();

conn.loadDriver();

conn.setConnection();

Connection con = conn.getConnection();

StudentDAO.insert(con, s);

DBClose.close(con);

}

public static Vector<Student> select() {

DBConnection conn = new DBConnection();

conn.loadDriver();

conn.setConnection();

Connection con = conn.getConnection();

String sql = "SELECT hakbun, irum, kor, eng, mat, edp ";

sql += " FROM Student";

Vector<Student> vector = StudentDAO.getAllData(con, sql, false);

DBClose.close(con);

return vector;

}

}

import java.sql.Connection;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.sql.Statement;

import java.util.Vector;

public class StudentDAO {

//원본보기

public static Vector<Student> getAllData(Connection conn, String sql, boolean isFull){

Vector<Student> vector = new Vector<Student>(1,1);

Statement stmt = null;

ResultSet rs = null;

try {

stmt = conn.createStatement();

rs = stmt.executeQuery(sql);

while(rs.next()){

Student s = new Student();

s.setHakbun(rs.getString("hakbun"));

s.setName(rs.getString("irum"));

s.setKor(rs.getInt("kor"));

s.setEng(rs.getInt("eng"));

s.setMat(rs.getInt("mat"));

s.setEdp(rs.getInt("edp"));

if(false){

s.setTot(rs.getInt("tot"));

s.setAvg(rs.getDouble("avg"));

s.setGrade(rs.getString("grade").charAt(0));  //"A" --> 'A'

}

vector.addElement(s);

}

} catch (SQLException e) {

e.printStackTrace();

}

return vector;

}

//학번으로 검색

public static Vector<Student> getOneData(Connection conn, String hakbun){

Vector<Student> vector = new Vector<Student>(1);

Statement stmt = null;   ResultSet rs = null;

try {

stmt = conn.createStatement();

String sql = "SELECT * FROM Student WHERE hakbun = '" + hakbun + "' ";

rs = stmt.executeQuery(sql);

rs.next();

Student s = new Student();

s.setHakbun(rs.getString("hakbun"));

s.setName(rs.getString("irum"));

s.setKor(rs.getInt("kor"));

s.setEng(rs.getInt("eng"));

s.setMat(rs.getInt("mat"));

s.setEdp(rs.getInt("edp"));

vector.addElement(s);

rs.close();

stmt.close();

} catch (SQLException e) {

e.printStackTrace();

}

return vector;

}

public static void insert(Connection conn, Student s){

Statement stmt = null;

try {

stmt = conn.createStatement();

String sql = "INSERT INTO Student(hakbun, irum, kor, eng, mat, edp) ";

sql += "VALUES('" + s.getHakbun() + "', '" + s.getName() + "', ";

sql += s.getKor() + ", " + s.getEng() + ", " + s.getMat() + ", ";

sql += s.getEdp() + ")";

stmt.executeUpdate(sql);

stmt.close();

} catch (SQLException e) {

e.printStackTrace();

}

}

}

import java.sql.Connection;

import java.util.Vector;

import javax.swing.table.DefaultTableModel;

public class StudentModel extends DefaultTableModel {

private int choice;

public StudentModel(int choice) {

this.choice = choice;

setModelData();

}

private void setModelData(){

Vector<String> columnVector = new Vector<String>(1,1);

String [] array = {"학번", "이름", "국어", "영어", "수학", "전산", "총점",

                  "평균", "학점", "등수"};

for(int i = 0 ; i < this.choice ; i++)  columnVector.addElement(array[i]);

Vector<Student> dataVector = StudentController.select();

Vector<Object> tableVector = new Vector<Object>(1,1);

for(int i = 0 ; i < dataVector.size() ; i++){

Vector<String> tempVector = new Vector<String>(1,1);

Student s = dataVector.get(i);

tempVector.addElement(s.getHakbun());

tempVector.addElement(s.getName());

tempVector.addElement(String.valueOf(s.getKor()));

tempVector.addElement(String.valueOf(s.getEng()));

tempVector.addElement(String.valueOf(s.getMat()));

tempVector.addElement(String.valueOf(s.getEdp()));

tableVector.addElement(tempVector);

}

this.setDataVector(tableVector, columnVector);

}

}

------------------------------------------------------------------------------

================================================================================

ㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡ

전화요금관리프로그램 (찾기기능없음), 

public class CustomerVO {

private int gubun;

private String telnum;

private String irum;

private int howmany;

private int gibon;

private int fee;

private int tax;

private int total;

public CustomerVO(){}

public CustomerVO(int gubun, String telnum, String irum, int howmany) {

this.gubun = gubun;

this.telnum = telnum;

this.irum = irum;

this.howmany = howmany;

}

@Override

public String toString(){

return String.format("%d\t%s\t%s\t%,d\t%,d\t%,d\t%,d",

                   this.gubun, this.telnum, this.irum, this.gibon,

                   this.fee, this.tax, this.total);

}

public int getGubun() {

return gubun;

}

public void setGubun(int gubun) {

this.gubun = gubun;

}

public String getTelnum() {

return telnum;

}

public void setTelnum(String telnum) {

this.telnum = telnum;

}

public String getIrum() {

return irum;

}

public void setIrum(String irum) {

this.irum = irum;

}

public int getHowmany() {

return howmany;

}

public void setHowmany(int howmany) {

this.howmany = howmany;

}

public int getGibon() {

return gibon;

}

public void setGibon(int gibon) {

this.gibon = gibon;

}

public int getFee() {

return fee;

}

public void setFee(int fee) {

this.fee = fee;

}

public int getTax() {

return tax;

}

public void setTax(int tax) {

this.tax = tax;

}

public int getTotal() {

return total;

}

public void setTotal(int total) {

this.total = total;

}

}

import java.util.Scanner;

public class Main {

public static void main(String[] args) {

System.out.println("<<전화요금관리프로그램>>");

Scanner scan = new Scanner(System.in);

Main main = new Main();

int choice = 0;

while(true){

choice = main.showMenu(scan);

if(choice == 4) break;

switch(choice){

case 1 : Input input = new Input(scan);  input.input(); break; 

case 2 : Output output = new Output(); break;

//case 3 :

}

}

System.out.println("Program is over...");

}

int showMenu(Scanner scan){

System.out.println("1:입력, 2:출력, 3:검색, 4:종료");

System.out.print(">> ");

return scan.nextInt();

}

}

import java.util.Scanner;

public class Input {

private Scanner scan;

Input(Scanner scan){

this.scan = scan;

}

void input(){

System.out.print("구분 : ");   int gubun = this.scan.nextInt();

System.out.print("전화번호 : "); String telnum = this.scan.next();

this.scan.nextLine();

System.out.print("성명 : "); String irum = this.scan.nextLine();

System.out.print("통화량 : ");  int howmany = this.scan.nextInt();

this.scan.nextLine();

CustomerVO c = new CustomerVO(gubun, telnum, irum, howmany);

Calc calc = new Calc(c);

CustomerController.insert(c);

}

}

public class Calc {

private CustomerVO c;

Calc(CustomerVO c){

this.c = c;

calc();

}

void calc(){

//1)입력되는 값이 구분이 1이면 영업용, 2이면 관청용, 3이면 가정용이다.

int gibon = (c.getGubun() == 1) ? 6000 :

                 (c.getGubun() == 2) ? 4800 : 3000;

//2)기본요금은 영업용이 6,000원, 관청용이 4,800원, 가정용이 3,000원이다.

//3)통화료는 1통화에 대하여 12원이다.

int fee = c.getHowmany() * 12;

//4)세금은 기본 요금과 통화료를 합한 금액의 10%를 부과한다.

int tax = (int)((gibon + fee) * 0.1);

int total = gibon + fee + tax;

c.setGibon(gibon);

c.setFee(fee);

c.setTax(tax);

c.setTotal(total);

}

}

import java.sql.Connection;

import java.util.Vector;

public class CustomerController {

public static void insert(CustomerVO c){

DBConnection db = new DBConnection();

db.loadDriver();

db.setConnection();

Connection conn = db.getConnection();

CustomerDAO.insert(conn, c);

DBClose.close(conn);

}

public static Vector <CustomerVO> select(){

DBConnection db = new DBConnection();

db.loadDriver();

db.setConnection();

Connection conn = db.getConnection();

Vector<CustomerVO> vector = CustomerDAO.select(conn);

DBClose.close(conn);

return vector;

}

}

import java.sql.Connection;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.sql.Statement;

import java.util.Vector;

public class CustomerDAO {

public static Vector<CustomerVO> select(Connection conn){

Statement stmt = null;

ResultSet rs = null;

Vector<CustomerVO> vector = new Vector<CustomerVO>(1,1);

try {

stmt = conn.createStatement();

String sql = "SELECT * FROM Telephone";

rs = stmt.executeQuery(sql);

while(rs.next()){

CustomerVO c = new CustomerVO();

c.setGubun(rs.getInt("gubun"));

c.setTelnum(rs.getString("telnum"));

c.setIrum(rs.getString("irum"));

c.setGibon(rs.getInt("gibon"));

c.setFee(rs.getInt("fee"));

c.setTax(rs.getInt("tax"));

c.setTotal(rs.getInt("total"));

vector.addElement(c);

}

rs.close();

stmt.close();

} catch (SQLException e) {

e.printStackTrace();

}

return vector;

}

public static void insert(Connection conn, CustomerVO c){

Statement stmt = null;

try {

stmt = conn.createStatement();

StringBuffer sb = new StringBuffer("INSERT INTO Telephone ");

sb.append("VALUES('" + c.getTelnum() + "'," + c.getGubun());

sb.append(",'" + c.getIrum() + "'," + c.getHowmany());

sb.append("," + c.getGibon() + "," + c.getFee() + "," + c.getTax());

sb.append("," + c.getTotal() + ")");

//System.out.println(sb.toString());

stmt.executeUpdate(sb.toString());

stmt.close();

} catch (SQLException e) {

e.printStackTrace();

}

}

}

import java.sql.Connection;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.sql.Statement;

public class DBClose {

public static void close(Connection conn){

try{

if(conn != null) conn.close();

}catch(SQLException ex){

ex.printStackTrace();

}

}

public static void close(Connection conn, Statement stmt){

try{

if(stmt != null) stmt.close();

if(conn != null) conn.close();

}catch(SQLException ex){

ex.printStackTrace();

}

}

public static void close(Connection conn, Statement stmt, ResultSet rs){

try{

if(rs != null) rs.close();

if(stmt != null) stmt.close();

if(conn != null) conn.close();

}catch(SQLException ex){

ex.printStackTrace();

}

}

}

import java.io.FileInputStream;

import java.io.FileNotFoundException;

import java.io.IOException;

import java.sql.Connection;

import java.util.Properties;

public class DBConnection{

private Properties info = null;

private Connection conn = null;

public DBConnection(){

info = new Properties();

try{

info.load(new FileInputStream("D:\\Downloads\\dbinfo.properties"));

}catch(FileNotFoundException ex){ ex.printStackTrace(); 

}catch(IOException ex){ ex.printStackTrace(); }

}

public void loadDriver(){

try{

Class.forName(info.getProperty("DBDRIVER"));

}catch(ClassNotFoundException ex){

System.out.println("Class Not Found");

}

}

public void setConnection(){

String url = info.getProperty("DBURL");

String user = info.getProperty("DBUSER");

String passwd = info.getProperty("DBPASSWORD");

try{

conn = java.sql.DriverManager.getConnection(url, user, passwd);

}catch(java.sql.SQLException ex){

System.out.println("Cannot Connect Access");

}

}

public Connection getConnection(){

if(this.conn != null) return this.conn;

else return null;

}

}

import java.util.Vector;

public class Output {

Output(){

Vector<CustomerVO> vector = CustomerController.select();

for(int i = 0 ; i < vector.size() ; i++){

CustomerVO c = vector.get(i);

System.out.println(c);

}

}

}

자바 네트워크 : UDP

import java.io.IOException;

import java.net.DatagramPacket;

import java.net.DatagramSocket;

import java.net.InetAddress;

import java.net.SocketException;

import java.text.SimpleDateFormat;

import java.util.Date;

public class UDPTimeServer {

private DatagramSocket server;

private DatagramPacket rPacket, sPacket;

private UDPTimeServer(){

try{

this.server = new DatagramSocket(9999);

System.out.println("Server is ready...");

}catch(SocketException ex){

ex.printStackTrace();

}catch(Exception ex){

ex.printStackTrace();

}

}

private void service(){

String pattern = "지금은 yyyy-MM-dd aa HH:mm:ss 입니다.";

SimpleDateFormat sdf = new SimpleDateFormat(pattern);

try{

while(true){

byte [] buffer = new byte[10];

this.rPacket = new DatagramPacket(buffer, buffer.length);  //받는 패킷

this.server.receive(rPacket);   //수신

InetAddress ia = rPacket.getAddress();  //client 주소

int port = rPacket.getPort();   //client port number

String msg = sdf.format(new Date());

this.sPacket = new DatagramPacket(msg.getBytes(), msg.getBytes().length, ia, port);

this.server.send(sPacket);   //발송

}

}catch(IOException ex){

ex.printStackTrace();

}

}

public static void main(String[] args) {

new UDPTimeServer().service();

}

}

import java.io.IOException;

import java.net.DatagramPacket;

import java.net.DatagramSocket;

import java.net.InetAddress;

import java.net.SocketException;

import java.net.UnknownHostException;

public class UDPTimeClient {

public static void main(String[] args) 

throws SocketException, UnknownHostException, InterruptedException,

IOException {

DatagramSocket client = new DatagramSocket();   

for(int i = 0 ; i < 10 ; i++){

DatagramPacket sPacket = new DatagramPacket("".getBytes(), "".getBytes().length, InetAddress.getByName("localhost"), 9999);  //""를 주어 아무것도 안보냄... 왜그런진 몰라...ㅠㅠ

Thread.sleep(1000);

client.send(sPacket);

byte [] buffer = new byte[512];

DatagramPacket rPacket = new DatagramPacket(buffer, buffer.length);

client.receive(rPacket);

String msg = new String(buffer, 0, rPacket.getLength());

System.out.println(msg);

}

client.close();

}

}

출력:

지금은 2014-04-03 AM 10:33:23 입니다.

지금은 2014-04-03 AM 10:33:24 입니다.

지금은 2014-04-03 AM 10:33:25 입니다.

지금은 2014-04-03 AM 10:33:26 입니다.

지금은 2014-04-03 AM 10:33:27 입니다.

지금은 2014-04-03 AM 10:33:28 입니다.

지금은 2014-04-03 AM 10:33:29 입니다.

지금은 2014-04-03 AM 10:33:30 입니다.

지금은 2014-04-03 AM 10:33:31 입니다.

지금은 2014-04-03 AM 10:33:32 입니다.

----------------------------------------------------------

import java.net.DatagramPacket;

import java.net.DatagramSocket;

import java.net.SocketException;

public class UDPServer {

private DatagramSocket server;

private DatagramPacket rPacket, sPacket;

UDPServer(){

try{

this.server = new DatagramSocket(9999);

System.out.println("Server is ready...");

}catch(SocketException ex){

ex.printStackTrace();

}

}

private void service(){

try{

while(true){

byte [] buffer = new byte[512];

this.rPacket = new DatagramPacket(buffer, buffer.length);

this.server.receive(rPacket);

String msg = new String(buffer, 0, rPacket.getLength());

if(msg.equals("bye")) break;

System.out.println("Client 로 부터 받은 문자열 : " + msg);

this.sPacket = new DatagramPacket(

msg.getBytes(), msg.getBytes().length, 

rPacket.getAddress(), rPacket.getPort());

this.server.send(sPacket);

}

}catch(Exception ex){

ex.printStackTrace();

}finally{

System.out.println("Server is closed...");

try{

this.server.close();

}catch(Exception ex){}

}

}

public static void main(String[] args) {

new UDPServer().service();

}

}

import java.net.DatagramPacket;

import java.net.DatagramSocket;

import java.net.InetAddress;

import java.net.SocketException;

import java.util.Scanner;

public class UDPClient {

private DatagramSocket client;

private DatagramPacket rPacket, sPacket;

private Scanner scan;

UDPClient() {

try{

this.client = new DatagramSocket();

this.scan = new Scanner(System.in);

System.out.println("발송준비완료");

}catch(SocketException ex){

ex.printStackTrace();

}

}

private void service(){

String line = null;

try{

while(true){

System.out.print(">> ");

line = this.scan.nextLine();

if(line == null || line.equals("bye")){

line = "bye";

break;

}

this.sPacket = new DatagramPacket(line.getBytes(), line.getBytes().length,

                       InetAddress.getByName("localhost"), 9999);

this.client.send(sPacket);  //서버로 발송

byte [] buffer = new byte[512];

this.rPacket = new DatagramPacket(buffer, buffer.length);

this.client.receive(rPacket);

String msg = new String(buffer, 0, rPacket.getLength());

System.out.println("서버로부터 들어온 문자열 : " + msg);

}

}catch(Exception ex){

ex.printStackTrace();

}finally{

try{

this.client.close();

}catch(Exception ex){}

}

}

public static void main(String[] args) {

new UDPClient().service();

}

}

출력:

java UDPClient

발송준비완료

>> 헤헷

서버로부터 들어온 문자열 : 헤헷

>> 으음..

서버로부터 들어온 문자열 : 으음..

ㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡ

NIO

Byte Buffer

import java.nio.ByteBuffer;

// position <= limit <= capacity

public class BufferDemo {

public static void main(String[] args) {

ByteBuffer bb = ByteBuffer.allocate(12);  //12바이트로 만들어줌.

System.out.println(bb);  //처음에 position은 0, limit와 capacity는 12

bb.putInt(100);  //100이 4바이트를 차지하니, 포지션 4이동.

System.out.println(bb);  

bb.putDouble(89.5);  //더블형 8바이트가 들어왓으니 포지션 12.

System.out.println(bb);  

//bb.put((byte)5);  //오류발생. 포지션이 리미트를 넘어감

bb.rewind();  //position이 처음위치 0으로이동

System.out.println(bb);    

System.out.println(bb.getInt());

System.out.println(bb);

System.out.println(bb.getDouble());

System.out.println(bb);

}

}

출력:

java.nio.HeapByteBuffer[pos=0 lim=12 cap=12]

java.nio.HeapByteBuffer[pos=4 lim=12 cap=12]

java.nio.HeapByteBuffer[pos=12 lim=12 cap=12]

java.nio.HeapByteBuffer[pos=0 lim=12 cap=12]

100

java.nio.HeapByteBuffer[pos=4 lim=12 cap=12]

89.5

java.nio.HeapByteBuffer[pos=12 lim=12 cap=12]

----------------------

import java.nio.ByteBuffer;

public class BufferDemo {

public static void main(String[] args) {

ByteBuffer bb = ByteBuffer.allocate(12);  //12바이트로 만들어줌.

System.out.println(bb);  //처음에 position은 0, limit와 capacity는 12

bb.putInt(100);  //100이 4바이트를 차지하니, 포지션 4이동.

System.out.println(bb);

bb.flip();  //psition을 0으로 옮기고, 원래 position의 값은 lim로 바꿔줌.

System.out.println(bb);

}

}

출력:

java.nio.HeapByteBuffer[pos=0 lim=12 cap=12]

java.nio.HeapByteBuffer[pos=4 lim=12 cap=12]

java.nio.HeapByteBuffer[pos=0 lim=4 cap=12]

-----------------------------------------------------------

Int Buffer

import java.nio.IntBuffer;

public class BufferDemo1 {

public static void main(String[] args) {

IntBuffer ib = IntBuffer.allocate(10);  //int형으로 10칸할당해주어서 40바이트. 한칸당4바이트.

System.out.println(ib);

ib.put(4).put(5).put(6).put(7).put(8).put(9);

System.out.println(ib);

ib.flip();  //position은 0으로, 마지막 position의 위치를 limit로.

System.out.println(ib);

while(ib.hasRemaining()){  //ib의 값이 있을 때까지

System.out.print(ib.get() + ",");

}

}

}

출력:

java.nio.HeapIntBuffer[pos=0 lim=10 cap=10]

java.nio.HeapIntBuffer[pos=6 lim=10 cap=10]

java.nio.HeapIntBuffer[pos=0 lim=6 cap=10]

4,5,6,7,8,9,

ㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡ

속도측정 - IO

import java.io.IOException;

public class Main {

public static void main(String[] args) throws IOException{

FullBuffer.start();

FullBuffer.copy("/home/mino/Downloads/staruml.exe", "/home/mino/Temp/staruml.exe" );

FullBuffer.end();

long differ = FullBuffer.during();

System.out.println(differ + " ms");

}

}

위에 메인에서만 FullBuffer를 SmallBuffer, NonBuffer로 바꿔주어 실행해 보면 아래의 결과값.

버퍼링을 하지 않을때

import java.io.FileInputStream;

import java.io.FileOutputStream;

import java.io.IOException;

public class NonBuffer {

private static long start;

private static long end;

public static void start()  { start = System.currentTimeMillis(); }

public static void end()  { end = System.currentTimeMillis();  }

public static long during() { return end - start; }

public static void copy(String source, String target) throws IOException {

FileInputStream fis = new FileInputStream(source);

FileOutputStream fos = new FileOutputStream(target);

int su = 0 ;

while((su = fis.read()) != -1){

fos.write(su);

}

System.out.println("Copy End...");

}

}

출력:

Copy End...

42508 ms

버퍼링을 살짝 할때

import java.io.FileInputStream;

import java.io.FileOutputStream;

import java.io.IOException;

public class SmallBuffer {

private static long start;

private static long end;

public static void start()  { start = System.currentTimeMillis(); }

public static void end()  { end = System.currentTimeMillis();  }

public static long during() { return end - start; }

public static void copy(String source, String target) throws IOException {

FileInputStream fis = new FileInputStream(source);

FileOutputStream fos = new FileOutputStream(target);

int count = 0;

byte [] buffer = new byte[1024];

while((count = fis.read(buffer)) != -1){

fos.write(buffer, 0, count);

}

System.out.println("Copy End...");

}

}

출력:

Copy End...

88 ms

버퍼링을 완전 쓸때

import java.io.FileInputStream;

import java.io.FileOutputStream;

import java.io.IOException;

public class FullBuffer {

private static long start;

private static long end;

public static void start()  { start = System.currentTimeMillis(); }

public static void end()  { end = System.currentTimeMillis();  }

public static long during() { return end - start; }

public static void copy(String source, String target) throws IOException {

FileInputStream fis = new FileInputStream(source);

FileOutputStream fos = new FileOutputStream(target);

int count = 0;

byte [] buffer = new byte[fis.available()];

while((count = fis.read(buffer)) != -1){

fos.write(buffer, 0, count);

}

System.out.println("Copy End...");

}

}

출력:

Copy End...

57 ms

NIO로 했을때 

import java.io.FileInputStream;

import java.io.FileOutputStream;

import java.io.IOException;

import java.nio.MappedByteBuffer;

import java.nio.channels.FileChannel;

import java.nio.channels.FileChannel.MapMode;

public class FileChannelDemo {

private static long start;

private static long end;

public static void start()  { start = System.currentTimeMillis(); }

public static void end()  { end = System.currentTimeMillis();  }

public static long during() { return end - start; }

public static void copy(String source, String target) throws IOException {

FileInputStream fis = new FileInputStream(source);

FileOutputStream fos = new FileOutputStream(target);

FileChannel in = fis.getChannel();

FileChannel out = fos.getChannel();

MappedByteBuffer map = in.map(MapMode.READ_ONLY, 0, in.size()); //처음부터 파일채널의 사이즈만큼 읽어서

out.write(map);

System.out.println("Copy End...");

}

}

출력:

Copy End...

82 ms

in을 기준으로 transferTo를 써서 

import java.io.FileInputStream;

import java.io.FileOutputStream;

import java.io.IOException;

import java.nio.MappedByteBuffer;

import java.nio.channels.FileChannel;

import java.nio.channels.FileChannel.MapMode;

public class FileChannelDemo1 {

private static long start;

private static long end;

public static void start()  { start = System.currentTimeMillis(); }

public static void end()  { end = System.currentTimeMillis();  }

public static long during() { return end - start; }

public static void copy(String source, String target) throws IOException {

FileInputStream fis = new FileInputStream(source);

FileOutputStream fos = new FileOutputStream(target);

FileChannel in = fis.getChannel();

FileChannel out = fos.getChannel();

in.transferTo(0, in.size(), out);  //0~사이즈만큼 out 채널로 보냄.

System.out.println("Copy End...");

}

}

출력:

Copy End...

18 ms

output을 기준으로 transferFrom 사용

import java.io.FileInputStream;

import java.io.FileOutputStream;

import java.io.IOException;

import java.nio.channels.FileChannel;

public class FileChannelDemo2 {

private static long start;

private static long end;

public static void start()  { start = System.currentTimeMillis(); }

public static void end()  { end = System.currentTimeMillis();  }

public static long during() { return end - start; }

public static void copy(String source, String target) throws IOException {

FileInputStream fis = new FileInputStream(source);

FileOutputStream fos = new FileOutputStream(target);

FileChannel in = fis.getChannel();

FileChannel out = fos.getChannel();

out.transferFrom(in, 0, in.size());

System.out.println("Copy End...");

}

}

출력:

Copy End...

23 ms

//transferFrom을 쓰면 가장빠르다는데.. 왜 난 transferTo가 더빠르지..?

ㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡ

===================================================================

ㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡ

                JDBC      

미리준비한 offic txt와 img파일을 vm윈도우로 옮겨줌.

데몬으로 설치해주고. Customize 선택해서 access 체크된것만 확인. 그리고 인스톨.

우편번호 다운. http://www.epost114.co.kr/ . 우편번호 다운로드 클릭.

우정사업본부 고시 우편번호 DB (현재 사용되고 있는 전체 우편번호 DB임) 다운로드.

실행하면 풀리면서 c:에 우편번호파일 폴더가 생김.

ㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡ

ODBC 설정. Control Panel\All Control Panel Items\Administrative Tools\ODBC Data Sources 들어가서

System DSN 탭에서 Add눌러서 .mdb or .accdb 택하고 확인. data source name에 이름(난 access) 써주고(ODBC 이름), 데이터베이스 선택 을 눌러서 사용할 액세스파일을 지정해줌. 확인 확인

아이디와 암호를 줄것이라면system DSN에서 아까만든 access를 configure 누른 후 오른쪽 advanced 누르면 아이디 비번을 정해줄 수 있다. 아디scott, 비번tiger  해줌.

그리고 이클립스에서 window- other perspective 에서 sql Explorer 선택.

new-connection profile에서 name은 아무거나, Driver는 jdbc odbc bridget 해주고 URL : jdbc:odbc:access(access는 아까정한 odbc이름). User는 아무거나.

ㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡ

우편번호 검색

// 1. import하자

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.sql.Statement;

import java.util.Scanner;

public class JDBCDemo {

private static final String DRIVER = "sun.jdbc.odbc.JdbcOdbcDriver";

private static final String URL = "jdbc:odbc:access";  //ODBC name

public static void main(String[] args) {

//2. Driver Loading

try{

Class.forName(DRIVER);

System.out.println("Driver loading Success");

}catch(ClassNotFoundException ex){

System.out.println("Class Not Found");

}

//3. Database Connection

Connection conn = null;

try{

conn = DriverManager.getConnection(URL);  //원래 아이디 비번도 같이 써줘야 하는데 우린 설정을 안해서 안넣음.

System.out.println("Connection Success");

}catch(SQLException ex){

System.out.println("Connect failure");

}

//4. Statement 객체 생성

Statement stmt = null;

ResultSet rs = null;  //결과를 가져올 때 사용

Scanner scan = new Scanner(System.in);

System.out.print("찾고자 하시는 동/읍/면 이름 : ");

String dongName = scan.nextLine().trim();

try{

stmt = conn.createStatement();

//5. Query 실행

String sql = "SELECT zipcode, sido, gugun, dong ";  //마지막 dong뒤에는 띄어야함.

sql += "FROM zipcode WHERE dong LIKE '%" + dongName + "%'";  //문자열이 데이터베이스는 '', 자바는"

rs = stmt.executeQuery(sql);  //결과값을 resultset에 넣어줌.

//6. Query 결과 수행

while(rs.next()){

String zipcode = rs.getString(1);  //JDBC는 인덱스가 1부터 시작.

String sido = rs.getString("sido");  //몇번짼지모르면 이름으로 불러와도됨.

String gugun = rs.getString("gugun");

String dong = rs.getString("dong");

System.out.printf("(%s) %s %s %s\n", zipcode, sido, gugun, dong);

}

rs.close();

stmt.close();

}catch(SQLException ex){

ex.printStackTrace();

}

//7.DB Close

try{  //닫는건 거꾸로

if(rs != null) conn.close();

}catch(SQLException ex){}

}

}

centos 설치(오늘은 다운만)

www.centos.org 접속. get centos linux now 선택. download now 선택. 

http://ftp.daum.net/centos/6.5/isos/x86_64/CentOS-6.5-x86_64-bin-DVD1.iso  선택(빠른 것 아무거나 받아도됭)

import java.net.MalformedURLException;

import java.net.URL;

import java.util.Scanner;

//1. MalformedURLException를 이용해서 URL Parsing

public class URLDemo {

public static void main(String[] args) {

URLDemo ud = new URLDemo();

String urlStr = ud.getURL();

URL url = null;

try{

url = new URL(urlStr);

System.out.println("protocol : " + url.getProtocol());

System.out.println("hostname : " + url.getHost());

System.out.println("file : " + url.getPath() + url.getFile());

System.out.println("query string : " + url.getQuery());

System.out.println("port number : " + url.getPort());

System.out.println("default port number : " + url.getDefaultPort());

}catch(MalformedURLException ex){

System.out.println(ex.getMessage());

}

}

String getURL(){

System.out.print("URL : ");

Scanner scan = new Scanner(System.in);

return scan.next().trim();

}

}

출력:

URL : http://www.naver.com/index.html : 80

protocol : http

hostname : www.naver.com

file : /index.html/index.html

query string : null

port number : -1

default port number : 80

출력:

URL : http://software.naver.com/software/summary.nhn?softwareId=MFS_100040

protocol : http

hostname : software.naver.com

file : /software/summary.nhn/software/summary.nhn?softwareId=MFS_100040

query string : softwareId=MFS_100040

port number : -1

default port number : 80

출력:

URL : file:///home/mino/Downloads/sungjuk_utf8.dat

protocol : file

hostname : 

file : /home/mino/Downloads/sungjuk_utf8.dat/home/mino/Downloads/sungjuk_utf8.dat

query string : null

port number : -1

default port number : -1

--------------------------------------------------------------

import java.awt.BorderLayout;

import java.awt.Container;

import java.awt.event.ActionEvent;

import java.awt.event.ActionListener;

import java.io.BufferedReader;

import java.io.IOException;

import java.io.InputStream;

import java.io.InputStreamReader;

import java.net.MalformedURLException;

import java.net.URL;

import javax.swing.JFrame;

import javax.swing.JOptionPane;

import javax.swing.JScrollPane;

import javax.swing.JTextArea;

import javax.swing.JTextField;

//2. openStream() 을 이용해서 InputStream 객체 생성

public class URLDemo1 implements ActionListener {

private JFrame f;

private JTextArea area;

private JScrollPane scroll;

private JTextField tf;

private Container con;

private URLDemo1(){

this.f = new JFrame("My Browser");

this.con = this.f.getContentPane();

this.area = new JTextArea();

this.scroll = new JScrollPane(area, JScrollPane.VERTICAL_SCROLLBAR_ALWAYS,

                      JScrollPane.HORIZONTAL_SCROLLBAR_ALWAYS);

this.tf = new JTextField("http://", JTextField.LEFT);

this.tf.addActionListener(this);

}

private void display(){

this.f.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);

this.con.setLayout(new BorderLayout());

this.con.add("North", this.tf);

this.con.add("Center", this.scroll);

this.f.setSize(700, 500);

this.f.setVisible(true);

}

@Override

public void actionPerformed(ActionEvent evt){

URL url = null;

BufferedReader br = null;

try{

url = new URL(this.tf.getText().trim());

InputStream is = url.openStream();

br = new BufferedReader(new InputStreamReader(is));

String line = null;

while((line = br.readLine()) != null){

this.area.append(line + "\n");

}

} catch(MalformedURLException ex){

JOptionPane.showMessageDialog(this.f, ex.getMessage());

} catch(IOException ex){

JOptionPane.showMessageDialog(this.f, ex.getMessage());

} finally{

try{

br.close();

} catch(IOException ex){}

}

}

public static void main(String[] args) {

new URLDemo1().display();

}

}

출력은 텍스트필드에 www.naver.com을 치면 그 화면에 html내용을 다 읽어들인다.

----------------위 코드를 파일 출력

import java.awt.BorderLayout;

import java.awt.Container;

import java.awt.event.ActionEvent;

import java.awt.event.ActionListener;

import java.io.BufferedReader;

import java.io.BufferedWriter;

import java.io.File;

import java.io.FileWriter;

import java.io.IOException;

import java.io.InputStream;

import java.io.InputStreamReader;

import java.io.PrintWriter;

import java.net.MalformedURLException;

import java.net.URL;

import javax.swing.JFrame;

import javax.swing.JOptionPane;

import javax.swing.JScrollPane;

import javax.swing.JTextArea;

import javax.swing.JTextField;

//2. openStream() 을 이용해서 InputStream 객체 생성

public class URLDemo1 implements ActionListener {

private JFrame f;

private JTextArea area;

private JScrollPane scroll;

private JTextField tf;

private Container con;

private URLDemo1(){

this.f = new JFrame("My Browser");

this.con = this.f.getContentPane();

this.area = new JTextArea();

this.scroll = new JScrollPane(area, JScrollPane.VERTICAL_SCROLLBAR_ALWAYS,

                      JScrollPane.HORIZONTAL_SCROLLBAR_ALWAYS);

this.tf = new JTextField("http://", JTextField.LEFT);

this.tf.addActionListener(this);

}

private void display(){

this.f.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);

this.con.setLayout(new BorderLayout());

this.con.add("North", this.tf);

this.con.add("Center", this.scroll);

this.f.setSize(700, 500);

this.f.setVisible(true);

}

@Override

public void actionPerformed(ActionEvent evt){

URL url = null;

BufferedReader br = null;

PrintWriter pw = null;

try{

url = new URL(this.tf.getText().trim());

InputStream is = url.openStream();

br = new BufferedReader(new InputStreamReader(is));

String hostname = url.getHost();   //www.naver.com

hostname = hostname.substring(4, hostname.lastIndexOf("."));

pw = new PrintWriter(new BufferedWriter(new FileWriter(new File(hostname + ".txt"))));

String line = null;

while((line = br.readLine()) != null){

this.area.append(line + "\n");

pw.println(line);

pw.flush();

}

JOptionPane.showMessageDialog(this.f, "잘 저장됐습니다.");

} catch(MalformedURLException ex){

JOptionPane.showMessageDialog(this.f, ex.getMessage());

} catch(IOException ex){

JOptionPane.showMessageDialog(this.f, ex.getMessage());

} finally{

try{

br.close();  pw.close();

} catch(IOException ex){}

}

}

public static void main(String[] args) {

new URLDemo1().display();

}

}

//출력은 www.naver.com 을 치면 naver.txt로 저장됨. 

----------------------------------------------------

import java.io.IOException;

import java.net.MalformedURLException;

import java.net.URL;

import java.net.URLConnection;

import java.util.Iterator;

import java.util.List;

import java.util.Map;

import java.util.Scanner;

import java.util.Set;

//3. URL 의 openConnection() 을 이용해서 URLConnection 객체 생성

public class URLConnectionDemo {

public static void main(String[] args) {

String urlStr = new URLConnectionDemo().getURL();

URL url = null;

URLConnection conn = null;

try{

url = new URL(urlStr);

conn = url.openConnection();

Map<String, List<String>> map = conn.getHeaderFields();

Set<String> set = map.keySet();

Iterator<String> iters = set.iterator();

while(iters.hasNext()){

String key = iters.next();

System.out.print(key +" --> ");

List<String> list = map.get(key);

for(int i = 0 ; i < list.size() ; i++){

System.out.print(list.get(i) +", ");

}

System.out.println();

}

}catch(MalformedURLException ex){

}catch(IOException ex){}

}

String getURL(){

System.out.print("URL : ");

Scanner scan = new Scanner(System.in);

return scan.next().trim();

}

}

출력:

URL : http://www.naver.com

null --> HTTP/1.1 200 OK, 

Vary --> Accept-Encoding,User-Agent, 

Transfer-Encoding --> chunked, 

Date --> Wed, 02 Apr 2014 01:39:17 GMT, 

P3P --> CP="CAO DSP CURa ADMa TAIa PSAa OUR LAW STP PHY ONL UNI PUR FIN COM NAV INT DEM STA PRE", 

Connection --> close, 

Content-Type --> text/html; charset=UTF-8, 

Server --> nginx, 

Pragma --> no-cache, 

Cache-Control --> no-cache, no-store, must-revalidate, 

ㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡ

URL Encoder

import java.io.UnsupportedEncodingException;

import java.net.URLEncoder;

import java.util.Scanner;

public class URLEncoderDemo {

public static void main(String[] args) throws UnsupportedEncodingException {

String str = new URLEncoderDemo().getString();

String en = URLEncoder.encode(str, "KSC5601");

System.out.printf("%s --> %s\n", str, en);

}

String getString(){

System.out.print("Encoding 할 문자열 : ");

Scanner scan = new Scanner(System.in);

return scan.next().trim();

}

}

출력:

Encoding 할 문자열 : 안녕하세요

안녕하세요 --> %BE%C8%B3%E7%C7%CF%BC%BC%BF%E4

-----------------------------------------

URL Decoder

import java.io.UnsupportedEncodingException;

import java.net.URLDecoder;

import java.util.Scanner;

public class URLDecoderDemo {

public static void main(String[] args) throws UnsupportedEncodingException {

String str = new URLDecoderDemo().getString();

String de = URLDecoder.decode(str, "KSC5601");

System.out.printf("%s --> %s\n", str, de);

}

String getString(){

System.out.print("Decoding 할 문자열 : ");

Scanner scan = new Scanner(System.in);

return scan.next().trim();

}

}

출력:

Decoding 할 문자열 : %BE%C8%B3%E7%C7%CF%BC%BC%BF%E4

%BE%C8%B3%E7%C7%CF%BC%BC%BF%E4 --> 안녕하세요

ㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡ

TCP

Server

import java.io.BufferedReader;

import java.io.IOException;

import java.io.InputStream;

import java.io.InputStreamReader;

import java.net.ServerSocket;

import java.net.Socket;

public class TcpDemo {

private ServerSocket server;

private Socket client;

private TcpDemo(){

this.server = null;

try{

this.server = new ServerSocket(8080);

System.out.println("Server is just started...");

}catch(IOException ex){

System.out.println(ex.getMessage());

}

}

private void service(){

BufferedReader br = null;

try{

this.client = this.server.accept();

System.out.println("[" + this.client.getInetAddress().getHostAddress() + "] 접속성공");

InputStream is = this.client.getInputStream();

String line = null;

br = new BufferedReader(new InputStreamReader(is));

while((line = br.readLine()) != null){

System.out.println(line);

}

}catch(IOException ex){

System.out.println(ex.getMessage());

}finally{

try{

this.client.close();

br.close();

}catch(IOException ex){}

}

}

public static void main(String[] args) {

new TcpDemo().service();

}

}

//쓰레드를 안만들어서 동시성이없다. 쓰레드를 만들어야함.

출력: 웹페이지에서 http://localhost:8080 입력. or http://Ubuntu-22:8080 (Ubuntu-22는 내 컴퓨터이름)

Server is just started...

[127.0.0.1] 접속성공

GET / HTTP/1.1

Host: ubuntu-22:8080

Connection: keep-alive

Accept: text/html,application/xhtml+xml,application/xml;q=0.9,image/webp,*/*;q=0.8

User-Agent: Mozilla/5.0 (X11; Linux i686) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/33.0.1750.152 Safari/537.36

Accept-Encoding: gzip,deflate,sdch

Accept-Language: en-US,en;q=0.8

출력: 웹페이지에서 http://localhost:8080/abc/def/ghi.test.html  입력.

Server is just started...

[127.0.0.1] 접속성공

GET /abc/def/ghi.test.html HTTP/1.1

Host: localhost:8080

Connection: keep-alive

Cache-Control: max-age=0

Accept: text/html,application/xhtml+xml,application/xml;q=0.9,image/webp,*/*;q=0.8

User-Agent: Mozilla/5.0 (X11; Linux i686) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/33.0.1750.152 Safari/537.36

Accept-Encoding: gzip,deflate,sdch

Accept-Language: en-US,en;q=0.8

//접속해서 들어온 클라이언트의 정보를 알 수 있다. 크롬으로 접속했으며등등~~

--------------------------------내보낼때

import java.io.BufferedReader;

import java.io.File;

import java.io.FileReader;

import java.io.IOException;

import java.io.InputStream;

import java.io.InputStreamReader;

import java.io.OutputStream;

import java.io.OutputStreamWriter;

import java.io.PrintWriter;

import java.net.ServerSocket;

import java.net.Socket;

public class TcpDemo {

private ServerSocket server;

private Socket client;

private TcpDemo(){

this.server = null;

try{

this.server = new ServerSocket(8080);

System.out.println("Server is just started...");

}catch(IOException ex){

System.out.println(ex.getMessage());

}

}

private void service(){

BufferedReader br = null;

PrintWriter pw = null;

try{

this.client = this.server.accept();

System.out.println("[" + this.client.getInetAddress().getHostAddress() + "] 접속성공");

InputStream is = this.client.getInputStream();

String line = null;

br = new BufferedReader(new InputStreamReader(is));

line = br.readLine(); //GET /index.html HTTP/1.1

int start = line.indexOf(" "); //3

int last = line.lastIndexOf("HTTP"); //16

line = line.substring(start +2, last);  //index.html 만 뽑기 위해서

String filename = null;

if(line.length() == 1) filename = "index.html";

else filename = line;

//System.out.println(filename);

OutputStream os = this.client.getOutputStream();  //client로 전송할 객체

File file = new File(filename);

pw = new PrintWriter(new OutputStreamWriter(os));

br = null;

br = new BufferedReader(new FileReader(file));

line = null;

while((line = br.readLine()) != null){  //index.html파일로부터 읽기

pw.println(line);

pw.flush();

}

while(line = p)

}catch(IOException ex){

System.out.println(ex.getMessage());

}finally{

try{

this.client.close();

br.close();

pw.close();

}catch(IOException ex){}

}

}

public static void main(String[] args) {

new TcpDemo().service();

}

}

그리고 다른컴퓨터에서 html파일로 아래와 같이 만들어서 이름을 index.html 로 주고 tcp.class와 같은 폴더에 저장한다.

<html>

 <head>

  <meta charset="UTF-8">

  <title>Welcome! my hompage...</title>

 </head>

 <body bgcolor='yellow'>

    <font size='7' color='red'><b>Hello, World</font>

 </body>

</html>

실행시키면 노랑바탕에 빨강 글씨로 나온다. 

그리고 서버를 열고.....

이제 내컴퓨터에서 웹페이지에서 접속할 아이피:8080 을 쓰면 index.html 페이지가 열린다

---------------------------------------------------------------

쓰레드까지 추가. 그러면 여러번 한번접속후 종료하지않고 계속 받을 수 있음.

import java.io.BufferedReader;

import java.io.PrintWriter;

import java.net.ServerSocket;

import java.net.Socket;

public class Apache {

private ServerSocket server;

private Socket client;

Apache(){

try{

this.server = new ServerSocket(8081);

System.out.println("Server is ready...");

while(true){

this.client = this.server.accept();

ClientThread ct = new ClientThread(this.client);

ct.start();

}

}catch(Exception ex){

System.out.println(ex.getMessage());

}

}

public static void main(String[] args) {

new Apache();

}

}

import java.io.BufferedReader;

import java.io.BufferedWriter;

import java.io.File;

import java.io.FileReader;

import java.io.InputStream;

import java.io.InputStreamReader;

import java.io.OutputStream;

import java.io.OutputStreamWriter;

import java.io.PrintWriter;

import java.net.Socket;

public class ClientThread extends Thread {

private Socket client;

private BufferedReader br;

private PrintWriter pw;

ClientThread(Socket client){

this.client = client;

try {

InputStream is = this.client.getInputStream();

OutputStream os = this.client.getOutputStream();

this.br = new BufferedReader(new InputStreamReader(is));

this.pw = new PrintWriter(new BufferedWriter(new OutputStreamWriter(os)));

} catch (Exception e) {

System.out.println(e.toString());

} 

}

@Override

public void run(){

//Thread 가 해야할 일

try{

String line = this.br.readLine();   //GET /index.html HTTP/1.1

int start = line.indexOf(" ");  //3

int last = line.lastIndexOf("HTTP");  //16

line = line.substring(start + 2, last);   //index.html

String filename = null;

if(line.length() == 1)  filename = "index.html";

else filename = line;

//파일을 읽을 BufferedReader

BufferedReader brTemp = 

new BufferedReader(new FileReader(new File(filename)));

line = null;

while((line = brTemp.readLine()) != null){  //파일로 부터 한 줄씩 읽어서

this.pw.println(line);

this.pw.flush();

}

brTemp.close();

}catch(Exception ex){

ex.printStackTrace();

}finally{

try{

if(this.br != null) this.br.close();

if(this.pw != null) this.pw.close();

}catch (Exception e) {

e.printStackTrace();

}

}

}

}

ㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡ

TCP 서버 클라이언트 : 잘 전송되는지 확인.

import java.io.BufferedReader;

import java.io.PrintWriter;

import java.net.ServerSocket;

import java.net.Socket;

public class TcpServer {

private ServerSocket server;

private Socket client;

private BufferedReader br;

private PrintWriter pw;

private TcpServer(){

try{

this.server = new ServerSocket(8888);

System.out.println("Server is ready...");

}catch(Exception ex){

ex.printStackTrace();

}

}

private void service(){

try{

while(true){

this.client = this.server.accept();

System.out.println(

"[" + this.client.getInetAddress().getHostAddress() + "] 님이 연결됐습니다." );

TcpThread tt = new TcpThread(this.client);

tt.start();

}

}catch(Exception ex){

ex.printStackTrace();

}finally{

System.out.println("Server is closed...");

try{

this.server.close();

}catch(Exception ex){

ex.printStackTrace();

}

}

}

public static void main(String[] args) {

new TcpServer().service();

}

}

import java.io.BufferedReader;

import java.io.BufferedWriter;

import java.io.InputStreamReader;

import java.io.OutputStreamWriter;

import java.io.PrintWriter;

import java.net.Socket;

public class TcpThread extends Thread{

private Socket client;

private BufferedReader br;

private PrintWriter pw;

TcpThread(Socket client){

this.client = client;

try{

this.br = new BufferedReader(

new InputStreamReader(this.client.getInputStream()));

this.pw = new PrintWriter(

new BufferedWriter(

new OutputStreamWriter(this.client.getOutputStream())));

}catch(Exception ex){

ex.printStackTrace();

}

}

@Override

public void run(){

//Thread 가 해야할 일

try{

String line = null;

while(true){

line = this.br.readLine();

if(line.equals("quit")) break;

System.out.println("String from Client : " + line);

this.pw.println(line);

this.pw.flush();

}

}catch(Exception ex){

ex.printStackTrace();

}finally{

try{

this.br.close();

this.pw.close();

}catch(Exception ex){

ex.printStackTrace();

}

}

}

}

import java.io.BufferedReader;

import java.io.BufferedWriter;

import java.io.InputStreamReader;

import java.io.OutputStreamWriter;

import java.io.PrintWriter;

import java.net.Socket;

import java.util.Scanner;

public class TcpClient {

private Socket socket;

private Scanner scan;

private String ip;

private int port;

private BufferedReader br;

private PrintWriter pw;

TcpClient(){

try{

this.scan = new Scanner(System.in);

this.getServerInfo();

this.socket = new Socket(ip, port);

System.out.println("[" + this.ip + "] connected...");

this.br = new BufferedReader(

new InputStreamReader(this.socket.getInputStream()));

this.pw = new PrintWriter(

new BufferedWriter(

new OutputStreamWriter(this.socket.getOutputStream())));

}catch(Exception ex){

ex.printStackTrace();

}

}

private void service(){

try{

String line = null;

while(true){

System.out.print("서버에 보낼 문자열 : ");

line = this.scan.nextLine().trim();

if(line == null || line.equals("quit")) {

this.pw.println("quit");

this.pw.flush();

break;

}

this.pw.println(line);

this.pw.flush();    //서버로 발송

System.out.println("서버로 부터 들어온 문자열 : " + this.br.readLine());

//서버에서 들어온 문자열

}

}catch(Exception ex){

ex.printStackTrace();

}finally{

try{

this.br.close();

this.pw.close();

}catch(Exception ex){

ex.printStackTrace();

}

}

}

public static void main(String[] args) {

TcpClient tc = new TcpClient();

tc.service();

}

void getServerInfo(){

System.out.print("Server IP : ");     this.ip = this.scan.nextLine();

System.out.print("Server Port Number : ");   this.port = this.scan.nextInt();

this.scan.nextLine(); //enter key 날리자.

}

}

ㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡ

채팅

import java.io.PrintWriter;

import java.net.ServerSocket;

import java.net.Socket;

import java.util.Hashtable;

public class ChatServer {

private ServerSocket server;

private Socket client;

ChatServer(){   //constructor

try{

this.server = new ServerSocket(9999);

System.out.println("Chatting Server is ready...");

Hashtable<String, PrintWriter> ht = new Hashtable<String, PrintWriter>();

while(true){

this.client = this.server.accept();

ChatServerThread cst = new ChatServerThread(this.client, ht);

cst.start();

}

}catch(Exception ex){

ex.printStackTrace();

}

}

public static void main(String[] args) {

new ChatServer();

}

}

import java.io.BufferedReader;

import java.io.BufferedWriter;

import java.io.InputStreamReader;

import java.io.OutputStreamWriter;

import java.io.PrintWriter;

import java.net.Socket;

import java.util.Collection;

import java.util.Hashtable;

import java.util.Iterator;

public class ChatServerThread extends Thread {

private Socket client;