Preparedstatement 인터페이스를 활용하여 자바 jdbc 효율적으로 컴파일해보자

안녕하세요

이번 시간에는 다시 자바 jdbc 진도를 나가려고 합니다.

아 자바도 좋지만,

요새 최순실 사태로 나라가 개판이네요...

정말 대한민국이 부끄럽습니다

빨리 박근혜가 하야하고 최순실도 구속하고 그 일가들 재산 모두 몰수 했으면 좋겠습니다


자 어쨋든 소스 코드와 결과 화면 보여드리겠습니다


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


public class PreparedStatementTest2 {

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

//메모 테이블의 내용을 수정하자 (작성자, 메모내용, 작성일)
Scanner sc = new Scanner(System.in);
System.out.println("수정할 글번호 입력=>"); // PK = WHERE 조건절
int idx = sc.nextInt();
System.out.println("수정할 작성자 입력=>");
String name = sc.next();
sc.skip("\r\n"); // 엔터값 건너뛰기
System.out.println("수정할 메모내용 입력=>");
String msg = sc.nextLine();
System.out.println(idx+"/"+name+"/"+msg);

FileReader fr = new FileReader("DB.properties");
Properties p = new Properties();
p.load(fr);

// 드라이버 로드
Class.forName(p.getProperty("driver"));
String url = p.getProperty("dburl");
String user = p.getProperty("user");
String pwd = p.getProperty("pwd");

Connection con = DriverManager.getConnection(url,user,pwd);
System.out.println("DB연결 성공");

//PreparedStatement는 sql문을 전처리(미리 컴파일)
//시켜놓기 때문에 객체를 얻어오기 전에 미리 sql문을 작성해 놓아야 한다.
String sql = "UPDATE memo SET name=?, msg=?, wdate=sysdate WHERE idx=?";
/* ?
* IN Parameter(?를 말함)
* PreparedStatment는 ?를 제외한 sql문을 DB 포맷에 맞게
* 컴파일 하여 미리 준비시켜 놓는다
* */

PreparedStatement pstmt=con.prepareStatement(sql); // ? 를 제외하고 이 때 딱 한번 컴파일함
//Statement stmt = con.createStatement(sql);

//DB에 전송하기 전에 IN Parameter 값 셋팅
pstmt.setString(1, name); // 첫번째 ?
pstmt.setString(2, msg); // 두번째 ?
pstmt.setInt(3, idx); // 세번째 ?

int cnt=pstmt.executeUpdate(); // DB에 전송

String str=(cnt>0)?"성공":"실패";
System.out.println(str);

pstmt.close();
con.close();
sc.close();


}

}


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

결과 화면




현재 오라클 memo 테이블에 위와 같이 데이터가 있습니다

저는 4번째 튜플을 바꾸겠습니다.

위의 작성한 소스코드를 run 하면

수정할 글번호,작성자,메모내용을 입력하라고 합니다

저는 4번째 데이터를 바꾸기 위해

작성자를 '최순실' 로, 메모내용을 '나는 역적입니다' 로 바꾸겠습니다

다시 오라클에서 조회하게 되면

짜잔~

4번째 튜플이 바뀌었네요 ㅎㅎ

아무튼 퍼킹 코리아 정신좀 차렸으면 좋겠습니다

텍스트가 아닌 파일 형태로 클라이언트가 서버에게 파일 전송하기 - Java~!!

안녕하세요

오늘도 자바 포스팅을 써봅니다.

지금까지 에코 서버/클라이언트, 실시간 채팅 모두 다 텍스트로만 데이터를 전송했습니다

이번 시간에는 텍스트 뿐만 아니라 파일을 전송할 수 있는 예제를 올려봅니다.

자 그럼 잘 봐주세요~!!


서버.java

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


//3 - FTPServer 자체가 스레드되게 바로 스레드 상속
public class FTPServer extends Thread {

private ServerSocket server;
private Socket sock;
private String upDir="C:/MyJava/Upload";
private ObjectInputStream ois; // 파일명, 파일 등을 받을 수 있는 스트림
private FileOutputStream fos; // 파일로 내보내는 스트림 - (동영상, 이미지) 파일 형태는 1바이트 기반이 적합 / 문자 형태는 2바이트 기반

public FTPServer(){
try {
server=new ServerSocket(7788);
} catch (Exception e) {
e.printStackTrace();
}

}

public void run(){
out.println("FTPServer Started...");
try {
while(true){
sock=server.accept();
out.println(sock.getInetAddress()+"가 접속해옴");
ois=new ObjectInputStream(sock.getInputStream());
//서버가 파일명을 보내오는 것을 받자
String fileName=ois.readUTF(); // 문자열을 받기 위해 readUTF 사용
out.println(fileName);
String path=upDir+"/"+fileName; // 절대경로 지정
fos=new FileOutputStream(path); // 절대경로에 파일을 내보내어 생성한다.

//서버가 파일을 보내오는 것을 받자
int input=0, count=0; // count는 파일 크기 측정하기 위해
byte[] data=new byte[1024]; // 1kb씩. 빠르게 하려면 값을 더 크게 줘도 된다

//C:/MyJava/Upload 경로에 파일을 내보내기
while((input=ois.read(data))!=-1){
fos.write(data, 0, input);
fos.flush();
count+=input;
out.println(count+"byte 업로드중...");
}

if(fos!=null) fos.close();
if(ois!=null) ois.close();
if(sock!=null) sock.close();
}

} catch (Exception e) {
e.printStackTrace();
}

}

public static void main(String[] args) {

FTPServer fserver=new FTPServer();
fserver.start();
}
}


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


클라이언트.java



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


package net.day2;

import java.io.*;
import java.net.*;
import javax.swing.ImageIcon;
import javax.swing.JFileChooser;
import javax.swing.JLabel;
import javax.swing.JOptionPane;

//3
//192.168.10.3
public class FileUploadGUI extends javax.swing.JFrame {

Socket sock;
     ObjectOutputStream oos;
     FileInputStream fis;
     File file1;
     PrintWriter pw;

    public FileUploadGUI() {
        initComponents();
    }

    @SuppressWarnings("unchecked")
    // <editor-fold defaultstate="collapsed" desc="Generated Code">                        
    private void initComponents() {

        jPanel1 = new javax.swing.JPanel();
        tfHost = new javax.swing.JTextField();
        tfFile = new javax.swing.JTextField();
        btFile = new javax.swing.JButton();
        btUpload = new javax.swing.JButton();
        lb = new javax.swing.JLabel();

        setDefaultCloseOperation(javax.swing.WindowConstants.EXIT_ON_CLOSE);
        setTitle("FileUpload");

        jPanel1.setBorder(new javax.swing.border.MatteBorder(null));

        tfHost.setText("localhost");
        tfHost.setBorder(javax.swing.BorderFactory.createTitledBorder("업로드 할 서버 IP 주소"));

        tfFile.setBorder(javax.swing.BorderFactory.createTitledBorder("업로드 할 파일명"));

        btFile.setText("파일찾기");
        btFile.addActionListener(new java.awt.event.ActionListener() {
            public void actionPerformed(java.awt.event.ActionEvent evt) {
                btFileActionPerformed(evt);
            }
        });

        btUpload.setText("Upload");
        btUpload.addActionListener(new java.awt.event.ActionListener() {
            public void actionPerformed(java.awt.event.ActionEvent evt) {
                btUploadActionPerformed(evt);
            }
        });

        javax.swing.GroupLayout jPanel1Layout = new javax.swing.GroupLayout(jPanel1);
        jPanel1.setLayout(jPanel1Layout);
        jPanel1Layout.setHorizontalGroup(
            jPanel1Layout.createParallelGroup(javax.swing.GroupLayout.Alignment.LEADING)
            .addGroup(jPanel1Layout.createSequentialGroup()
                .addContainerGap()
                .addGroup(jPanel1Layout.createParallelGroup(javax.swing.GroupLayout.Alignment.TRAILING, false)
                    .addComponent(tfFile)
                    .addComponent(tfHost, javax.swing.GroupLayout.DEFAULT_SIZE, 380, Short.MAX_VALUE))
                .addPreferredGap(javax.swing.LayoutStyle.ComponentPlacement.UNRELATED)
                .addGroup(jPanel1Layout.createParallelGroup(javax.swing.GroupLayout.Alignment.LEADING)
                    .addComponent(btFile, javax.swing.GroupLayout.DEFAULT_SIZE, 92, Short.MAX_VALUE)
                    .addComponent(btUpload, javax.swing.GroupLayout.DEFAULT_SIZE, javax.swing.GroupLayout.DEFAULT_SIZE, Short.MAX_VALUE))
                .addContainerGap())
        );
        jPanel1Layout.setVerticalGroup(
            jPanel1Layout.createParallelGroup(javax.swing.GroupLayout.Alignment.LEADING)
            .addGroup(jPanel1Layout.createSequentialGroup()
                .addContainerGap()
                .addGroup(jPanel1Layout.createParallelGroup(javax.swing.GroupLayout.Alignment.LEADING, false)
                    .addComponent(tfHost, javax.swing.GroupLayout.DEFAULT_SIZE, 54, Short.MAX_VALUE)
                    .addComponent(btUpload, javax.swing.GroupLayout.DEFAULT_SIZE, javax.swing.GroupLayout.DEFAULT_SIZE, Short.MAX_VALUE))
                .addPreferredGap(javax.swing.LayoutStyle.ComponentPlacement.UNRELATED)
                .addGroup(jPanel1Layout.createParallelGroup(javax.swing.GroupLayout.Alignment.LEADING, false)
                    .addComponent(btFile, javax.swing.GroupLayout.DEFAULT_SIZE, javax.swing.GroupLayout.DEFAULT_SIZE, Short.MAX_VALUE)
                    .addComponent(tfFile, javax.swing.GroupLayout.DEFAULT_SIZE, 55, Short.MAX_VALUE))
                .addContainerGap(25, Short.MAX_VALUE))
        );

        lb.setBorder(new javax.swing.border.SoftBevelBorder(javax.swing.border.BevelBorder.RAISED));

        javax.swing.GroupLayout layout = new javax.swing.GroupLayout(getContentPane());
        getContentPane().setLayout(layout);
        layout.setHorizontalGroup(
            layout.createParallelGroup(javax.swing.GroupLayout.Alignment.LEADING)
            .addGroup(javax.swing.GroupLayout.Alignment.TRAILING, layout.createSequentialGroup()
                .addContainerGap()
                .addGroup(layout.createParallelGroup(javax.swing.GroupLayout.Alignment.TRAILING)
                    .addComponent(lb, javax.swing.GroupLayout.DEFAULT_SIZE, javax.swing.GroupLayout.DEFAULT_SIZE, Short.MAX_VALUE)
                    .addComponent(jPanel1, javax.swing.GroupLayout.DEFAULT_SIZE, javax.swing.GroupLayout.DEFAULT_SIZE, Short.MAX_VALUE))
                .addContainerGap())
        );
        layout.setVerticalGroup(
            layout.createParallelGroup(javax.swing.GroupLayout.Alignment.LEADING)
            .addGroup(layout.createSequentialGroup()
                .addContainerGap()
                .addComponent(jPanel1, javax.swing.GroupLayout.PREFERRED_SIZE, javax.swing.GroupLayout.DEFAULT_SIZE, javax.swing.GroupLayout.PREFERRED_SIZE)
                .addGap(18, 18, 18)
                .addComponent(lb, javax.swing.GroupLayout.PREFERRED_SIZE, 331, javax.swing.GroupLayout.PREFERRED_SIZE)
                .addContainerGap(26, Short.MAX_VALUE))
        );

        pack();
    }// </editor-fold>                      

    JFileChooser fileDial=new JFileChooser("C:/MyJava/"); // 기준 경로 지정
    private void btFileActionPerformed(java.awt.event.ActionEvent evt) {                                      
       
    //파일 다이얼로그를 띄워 업로드할 파일을 선택한다
    fileDial.showOpenDialog(this);
    File selFile=fileDial.getSelectedFile();
    tfFile.setText(selFile.getAbsolutePath());
    String filename=selFile.getName();
    //파일이 이미지 파일이면 lb에 미리보기를 해주자
    filename=filename.toLowerCase(); // 파일 이름을 전부 소문자로 바꾸기
    if(filename.endsWith(".jpg")||filename.endsWith(".png")||filename.endsWith(".gif")){
    lb.setIcon(new ImageIcon(selFile.getAbsolutePath()));
    lb.setText("");
    lb.setHorizontalAlignment(JLabel.CENTER);
    }
    }                                    

    private void btUploadActionPerformed(java.awt.event.ActionEvent evt) {                                        
       
    // 파일을 서버에 전송하는 스레드 생성 및 동작
    SenderThread tr=new SenderThread();
    tr.start();
    }
   
    class SenderThread extends Thread{
   
    public void run(){
    // ftpserver에 접속하자(아이피, 포트번호)
    String serverip=tfHost.getText();
    int port=7788;
    if(serverip==null||serverip.trim().isEmpty()){
    JOptionPane.showMessageDialog(lb, "서버의 IP 주소를 입력하세요");
    tfHost.requestFocus();
    return;
    }//if------

    try{
    // 소켓 생성
    sock = new Socket(serverip, port);
    // 타이틀에 연결 결과 출력
    setTitle("##서버와 접속됨");
    //소켓 출력스트림=>ObjectOutputStream 필터링
    //클라이언트(OjbectInputStream)에게 파일을 보낸다
    oos = new ObjectOutputStream(sock.getOutputStream());
    //파일 입력스트림=>FileInputStream
    //File chooser에서 선택한 파일을 읽어들인다
    file1 = fileDial.getSelectedFile();
    fis = new FileInputStream(file1);
    //파일명을 서버에 전송한다.
    String fname = file1.getName();
    pw = new PrintWriter(sock.getOutputStream(),true);
    oos.writeUTF(fname);
    oos.flush();
    //파일을 읽으면서 소켓출력 스트림을 통해 파일 데이터를 내보낸다.
    int input=0, count=0;
    byte[] data = new byte[1024];
    while((input=fis.read(data))!=-1){
    oos.write(data, 0, input);
    oos.flush();
    count+=input;
    System.out.println(count+"바이트 전송중...");
    }
   
    if(pw!=null) pw.close();
    if(oos!=null) oos.close();
    if(fis!=null) fis.close();
    if(sock!=null) sock.close();
    JOptionPane.showMessageDialog(lb, "업로드 완료!");
    }catch(Exception e){
    System.out.println("예외: "+e);
    }
    }
    }

    public static void main(String args[]) {
        try {
            for (javax.swing.UIManager.LookAndFeelInfo info : javax.swing.UIManager.getInstalledLookAndFeels()) {
                if ("Nimbus".equals(info.getName())) {
                    javax.swing.UIManager.setLookAndFeel(info.getClassName());
                    break;
                }
            }
        } catch (ClassNotFoundException ex) {
            java.util.logging.Logger.getLogger(FileUploadGUI.class.getName()).log(java.util.logging.Level.SEVERE, null, ex);
        } catch (InstantiationException ex) {
            java.util.logging.Logger.getLogger(FileUploadGUI.class.getName()).log(java.util.logging.Level.SEVERE, null, ex);
        } catch (IllegalAccessException ex) {
            java.util.logging.Logger.getLogger(FileUploadGUI.class.getName()).log(java.util.logging.Level.SEVERE, null, ex);
        } catch (javax.swing.UnsupportedLookAndFeelException ex) {
            java.util.logging.Logger.getLogger(FileUploadGUI.class.getName()).log(java.util.logging.Level.SEVERE, null, ex);
        }
        //</editor-fold>

        /* Create and display the form */
        java.awt.EventQueue.invokeLater(new Runnable() {
            public void run() {
                new FileUploadGUI().setVisible(true);
            }
        });
    }

    // Variables declaration - do not modify                    
    private javax.swing.JButton btFile;
    private javax.swing.JButton btUpload;
    private javax.swing.JPanel jPanel1;
    private javax.swing.JLabel lb;
    private javax.swing.JTextField tfFile;
    private javax.swing.JTextField tfHost;
    // End of variables declaration                  
}

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


실행 결과 화면은 다음과 같습니다

서버를 실행하고 클라이언트를 실행하면 위와 같은 창이 나옵니다.

저는 제가 좋아하는 설현 움짤을 업로드 했습니다.

그리고 업로드 할 서버 IP 주소(자신의 IP) 주소를 적고

업로드 버튼을 누르면..

업로드가 완료됩니다.

이때 클라이언트, 서버 창에는 그동안 몇바이트를 업로드 했는지가 출력이 됩니다

위의 소스를 실행하기 위해서 반드시 'Upload' 라는 폴더가 있어야 합니다

그 폴더를 안만들고 백날 실행해봐야 되지 않습니다.

이 점 유의하시면서 이상 포스팅을 마칩니다

왓? 자바에서 서버 클라이언트 1대1 실시간 통신 예제가 있다고?

안녕하세요

이번 시간에는 이전 예제 에코 서버와 클라이언트의 정적인 채팅이 아닌

실시간 채팅 예제를 올려봅니다.

스레드 하나를 썼을 뿐인데 실시간이 지원되네요

어쨋든 소스 코드 올려봅니다.

렛츠고~!


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


public class ConsoleChatServer {

ServerSocket server;
Socket sock;
BufferedReader key, in;
PrintWriter pout;
final int port=7777;

public ConsoleChatServer(){
try {
out.println("ConsoleChatServer Started..");
server=new ServerSocket(port);
sock = server.accept();
out.println("##클라이언트와 연결됬음##["+sock.getInetAddress()+"]");
//1) 키보드 입력 스트림 생성
key=new BufferedReader(new InputStreamReader(System.in));
//2) 클라이언트의 메시지를 듣는 스트림
in=new BufferedReader(new InputStreamReader(sock.getInputStream()));
//3) 클라이언트에게 메시지를 보내는 스트림
pout=new PrintWriter(sock.getOutputStream(),true);
//4) 클라이언트의 메시지를 듣는 스레드 동작
ChatThread listener=new ChatThread();
listener.start();
//5) 키보드 입력을 통해 클라이언트에게 메시지를 보낸다
String mymsg="";
while((mymsg=key.readLine())!=null){
pout.println(mymsg);
}
} catch (Exception e) {
out.println("예외: "+e);
closeAll();
}
}// 생성자 ------------------------
//inner class
class ChatThread extends Thread{
// 클라이언트가 보내오는 메시지를 무한정 듣고 콘솔에 출력한다.
public void run(){
try{
while(true){
String cmsg=in.readLine();
out.println("From Client>>"+cmsg);

}//while------
}catch(IOException e){
out.println("예외:[클이 퇴장했어요] "+e);
closeAll();
}
}//run()------
} ///////////////////////
private void closeAll(){
try {
if(in!=null) in.close();
if(pout!=null) pout.close();
if(key!=null) key.close();
if(sock!=null) sock.close();
if(server!=null) server.close();
} catch (Exception e) {
out.println("closeAll()에서 예외 : "+e);
}
}
public static void main(String[] args) throws IOException {
new ConsoleChatServer();
}
}


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

위의 예제는 서버이고, 아래 예제는 클라이언트입니다.



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


public class ConsoleChatClient {

String ip="192.168.10.12";
final int port = 7777;
Socket sock;
//키보드입력, 서버로부터 듣는거
BufferedReader key, in;
PrintWriter pw;

//?
public ConsoleChatClient() throws IOException{
//소켓 객체 생성
sock = new Socket(ip, port);
out.println("##서버와 접속됨");

//필요한 스트림 생성 또는 할당
//키보드 입력
key = new BufferedReader(new InputStreamReader(System.in));

InputStream is=sock.getInputStream();
in = new BufferedReader(new InputStreamReader(is));

// PrintWriter 자체가 브리지 스트림을 안거친다. 그래서 BufferedWriter를 안쓴다
pw = new PrintWriter(sock.getOutputStream(),true);

//서버의 메시지를 듣는 스레드 생성 및 동작
ChatThread listener=new ChatThread();
listener.start();

//키보드 입력해서 서버에 메시지 전송
String mymsg="";
while((mymsg=key.readLine())!=null){
pw.println(mymsg);
}
}
class ChatThread extends Thread{
public void run(){
try {
while(true){
String smsg=in.readLine();
out.println("From Server>>"+smsg);
}
} catch (IOException e) {
out.println("예외:[서버가 퇴장했어요] "+e);
closeAll();
}
}
}
private void closeAll(){
try{
//순서? DB는 반드시 순서를 지켜야한다
if(in!=null) in.close();
if(key!=null) key.close();
if(pw!=null) pw.close();
if(sock!=null) sock.close();
}catch(IOException e){
out.println("closeAll()에서 예외 : "+e);
}
}

public static void main(String[] args) throws IOException { // 최종적으로 IOException은 JVM이 처리
new ConsoleChatClient();
}
}

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


사실 이번 예제는 이전 에코서버 예제와 그렇게 큰 차이는 없으나

스레드의 유무로 훨씬 더 개선된 퍼포먼스를 내는 채팅이 구현되었습니다.

자 그럼 실행화면 보실까요~!

위와 같이 서버를 실행하고 이후 클라이언트를 실행하면

서버에 접속되었다는 멘트가 출력이 됩니다

그리고 서버에게 '안녕하세요 클라이언트입니다' 라고 메시지를 보내게 되면

서버에서 클라이언트가 보낸 메시지가 출력이 되고

서버도 클라이언트에게 메시지를 보내면..

클라이언트도 서버가 보낸 메시지를 출력하게 됩니다

다음 예제에서도 알찬 예제로 찾아뵙겠습니답~!!

에코(Echo) 서버와 클라이언트를 구현해보장~!!

안녕하세요

이번 시간에는 자바에서 에코 서버와 클라이언트를 구현해보는 시간을 가지겠습니다

에코 서버는 클라이언트가 보내주는 데이터에 대해 바로 답장해주는 서버로

실시간 채팅과는 좀 더 폐쇄적이고 수동적인 채팅 스타일 방식을 가졌다고 보면 됩니다.

자 어쨋든 예제 바로 들어갑니다


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

* [구현할 내용
 * Client가 Server에 접속하면
 * [1] 서버는 먼저 클라이언트에게 "안녕하세요? 클라이언트(ip)님~~" 메시지를 보낸다
 * [2] 클라이언트는 키보드 입력을 통해 서버에 응답 메시지를 보낸다.
 * [3] 서버는 클라이언트이 메시지를 듣고 메시지를 분석해서 3가지 유형의 답변을 보낸다.
 * (1) "안녕하세요" 또는 "하이" 란 메시지가 오면 => "반가워요~~"
 *  (2) "오늘 날짜는" 이란 메시지가 오면 => 오늘 날짜를 알려준다
 *  (3) 그 외 다른 메시지가 오면 => '~~님 어여 가!!" 란 메시지를 보내자
 *
 * */

// 순차적인 채팅. 메아리 채팅임

public class EchoServer {

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

//ServerSocket, Socket
ServerSocket server=new ServerSocket(6666);
out.println("EchoServer Ready...");
Socket sock=server.accept();
String cip=sock.getInetAddress().getHostAddress(); // 클라이언트 IP 주소
out.println(cip+"님이 접속했어요");

//클라이언트가 접속하면 먼저 인사말을 건낸다
OutputStream os=sock.getOutputStream();
PrintWriter pout=new PrintWriter(os,true); // true값을 주면 auto flush
pout.println("안녕하세요? "+cip+"님~~");

// 클라이언트의 메시지를 듣는 스트림 얻기=> 필터링
InputStream is = sock.getInputStream();
BufferedReader br=new BufferedReader(new InputStreamReader(is));

// 반복문 돌면서 클라이언트이 메시지를 계속 듣고 그 메시지를 분석하여
// 메아리를 보낸다
//indexof 없으면 if(-1)

String cmsg="";
while((cmsg=br.readLine())!=null){
//cmsg를 분석하자
int i=cmsg.indexOf("안녕");
int j=cmsg.indexOf("하이");
int k=cmsg.indexOf("날짜");

if(i!=-1||j!=-1){
pout.println("반갑습니다");
}else if(k!=-1){
pout.println(new Date().toString());
}else{
pout.println(cip+"님 어여 가~~~");
}
}

br.close();
pout.close();
is.close();
os.close();
sock.close();
server.close();

}
}


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

현재 위의 소스는 에코서버쪽의 소스입니다.

자 다음은 에코 클라이언트의 소스입니다

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


public class EchoClient {

public static void main(String[] args) throws IOException {
//Socket생성=> 서버의 ip주소, port번호 필요
String ip=JOptionPane.showInputDialog("서버의 아이피 주소를 입력하세요");
int port=6666;

Socket sock=new Socket("ip주소",6666);
out.println("##서버와 접속됨");

//2) 서버에 접속하면 서버가 먼저 인사말을 건낸다.
//=> 클라이언트는 인사말을 듣고 콘솔에 출력하자
InputStream is=sock.getInputStream();
BufferedReader br=new BufferedReader(new InputStreamReader(is));
String serverMsg=br.readLine();
out.println("From Server>>"+serverMsg);

//3) 서버에 메시지를 보내기 위해 키보드 입력 스트림과 서버에 출력하는 스트림이 필요
//키보드 입력 스트림(System.in)
BufferedReader key=new BufferedReader(new InputStreamReader(System.in));

//4) 서버에 메시지를 보낼 출력스트림
PrintWriter pw=new PrintWriter(sock.getOutputStream(),true); // auto flush

String clientMsg="";

while((clientMsg=key.readLine())!=null){ // 키보드 입력
pw.println(clientMsg); // 5) 서버에 메시지를 전송
//6) 서버에서 보내오는 메시지를 듣는다
out.println("서버로부터 보낼 메시지를 입력하세요");
serverMsg=br.readLine();
out.println("From Server>>"+serverMsg);
}
}
}

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


자 이로써 두 개의 에코서버, 에코클라이언트 소스를 작성해봤습니다.

이 두 개의 소스코드의 실행결과는 아래와 같습니다(참고로 서버부터 먼저 실행해야합니다)

서버를 실행하면, 클라이언트의 접속을 무한정 기다립니다.

그리고 클라이언트를 실행하면 JOption 창이 뜨면서 서버의 아이피 주소를 입력하라고

나오게 됩니다.

접속이 되면 서버로부터 '안녕하세요' 라는 글귀가 나오고

서버에게 '날짜' 라는 키워드를 입력하면 서버가 날짜를 보내오고

안녕, 하이 라는 키워드를 입력하면 '반갑습니다' 라는 키워드를 보냅니다

SELECT 조회문을 활용하여 다양한 조건문 출력

안녕하세요

이번 시간에는 SELECT 조회문과 그 안에 다양한 함수들을 활용하여

여러 요구사항들을 해결하는 예제를 올려봅니다.

이것 역시도 어제와 그렇게 큰 난이도 차이가 나지 않네요


자 그럼 예제와 결과 화면을 보시죠

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

LOWER/UPPER
LOWER:대문자를 소문자로 바꿔 출력
UPPER:소문자를 대문자로 바꿔 출력

SELECT LOWER('HAPPY DAY') FROM DUAL;
SELECT UPPER('HAppy day') FROM DUAL;

SELECT 2*3 FROM EMP;
SELECT 2*3 FROM STUDENT;

DUAL이란 테이블에는 한 개의 행 밖에 없다.
연산이나 날짜 정보를 보기 위해 사용하는 테이블

SELECT SYSDATE,SYSTIMESTAMP FROM DUAL;

SELECT DNAME, INITCAP(DNAME) FROM DEPT;
INITCAP() : 첫글자만 대문자로

[1]EMP에서 20번 부서의 사원정보를 사번,이름,담당업무,부서번호를 가져오되 사원의 이름은 첫글자만 대문자로, 담당업무는 모두 소문자로, 사번 오름차순으로 가져오세요
SELECT * FROM EMP;
SELECT EMPNO,INITCAP(ENAME),LOWER(JOB),DEPTNO FROM EMP WHERE DEPTNO=20 ORDER BY EMPNO;



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

CONCAT(값1, 값2) : 두 개 이상의 문자나 컬럼을 서로 연결시켜주는 함수
SELECT CONCAT('ABCD','1234'), 'abcd'||'가나다' FROM DUAL;

SELECT EMPNO,ENAME,CONCAT(ENAME,JOB) FROM EMP;

SUBSTR(변수,INDEX,LEN) : 변수의 INDEX 위치에서 LEN 길이만큼의 문자를 반환
INDEX가 음수라면 문자는 끝에서부터 시작한다.

SELECT SUBSTR('ABCDEFG',2,3) FROM DUAL;
SELECT SUBSTR('ABCDEFG',-3,3) FROM DUAL;

[2]생년월일만 출력(99년 12월 25일)
SELECT SUBSTR('991225-1075112',1,2)||'년'||SUBSTR('991225-1075112',3,2)||'월'||SUBSTR('991225-1075112',5,2)||'일' FROM DUAL;




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

[3]주민번호 뒷자리(7개)만 출력
SELECT SUBSTR('991225-1075112',-7,7) FROM DUAL;



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

[4]사원테이블에서 사원의 이름 첫글자가 'K'보다 크고 'Y'보다 작은 사원의 사번,이름,업무를 출력하세요
SELECT * FROM EMP;
SELECT EMPNO,ENAME,JOB FROM EMP WHERE SUBSTR(ENAME,1,1)>'K' AND SUBSTR(ENAME,1,1)<'Y';



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

[5]상품(PRODUCTS) 테이블에서 출고가(OUTPUT_PRICE)를 가격단위('원')을 붙여서 상품명, "판매가격" 으로 출력하세요
SELECT * FROM PRODUCTS;
SELECT PRODUCTS_NAME, CONCAT(OUTPUT_PRICE,'원') "판매가격" FROM PRODUCTS ORDER BY OUTPUT_PRICE ASC;
--OUTPUT_PRICE||'원'



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

LENGTH(값) : 문자열 길이를 반환

[6]사원테이블에서 사원의 이름이 6자리 이상을 차지하는 사원의 이름과 업무, 이름 자릿수를 함께 출력하세요
SELECT ENAME,JOB,LENGTH(ENAME) FROM EMP WHERE LENGTH(ENAME)>=6;



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

LPAD / RPAD

LPAD(컬럼, 변수1, 변수2) : 문자값을 왼쪽부터 주어진 문자로 채움
전체자리를 15자리로 정하고 남는 문자열은 '*'로 채우겠다.
SELECT ENAME,LPAD(ENAME,15,'*'),SAL,LPAD(SAL,10,'-') FROM EMP;

SELECT DNAME,RPAD(DNAME,15,'*') FROM DEPT;

LTRIM / RTRIM
LTRIM(변수1,변수2)
:변수 1값 중에서 변수2와 같은 단어가 있을 경우 그 문자를 삭제한 나머지 값을 반환한다.

왼쪽 'A' 문자를 지운다
SELECT LTRIM('AAAHello Oracle AA', 'A') FROM DUAL;
오른쪽 'A' 문자를 지운다
SELECT RTRIM('AAAHello Oracle AA', 'A') FROM DUAL;

[7]' HELLO ORACLE ' 문자열의 앞 뒤 공백을 제거하여 출력하고, 문자열 길이도 출력하세요
SELECT LENGTH(TRIM(' HELLO ORACLE ')), RTRIM(LTRIM(' HELLO ORACLE ', ' ')) "공백 제거" FROM DUAL;



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

[8] 사원테이블에서 10번 부서 사원의 담당 업무 중 좌측에 'M'을 삭제하고 급여 중 좌측의 1을 삭제하여 출력하세요
SELECT * FROM EMP;
SELECT LTRIM(JOB, 'M'), LTRIM(SAL, '1') FROM EMP WHERE DEPTNO=10;



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

REPLACE(컬럼, 변수1, 변수2)
: 정해진 컬럼에서 지정한 문자를 특정 문자로 변경하는 함수

TEST ORACLE의 TEST 문자열을 HELLO로 바꾼다
SELECT REPLACE('TEST ORACLE', 'TEST', 'HELLO') FROM DUAL;

[9] 사원 테이블에서 업무가 'A'로 시작하는 업무를 'A'를 '$'로 바꿔 출력하세요
SELECT ENAME,JOB,REPLACE(JOB,'A','$') FROM EMP WHERE JOB LIKE 'A%';



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

[10] 고객(MEMBER)테이블에서 직업이 '학생'인 정보를 모두 '대학생'으로 변경해 출력하세요
SELECT NAME,JOB,REPLACE(JOB,'학생','대학생') FROM MEMBER;



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

[11] 고객 테이블 주소에서 '서울시'를 '서울특별시'로 수정하세요
SELECT * FROM MEMBER;
UPDATE MEMBER SET ADDR=REPLACE(ADDR,'서울시','서울특별시') WHERE ADDR LIKE '%서울시%';
ROLLBACK;





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

숫자형 함수
ROUND(값), ROUND(값1, 값2)

SELECT ROUND(4567.789), ROUND(4567.789,0), ROUND(4567.789,2), ROUND(4567.789,-2) FROM DUAL;
소수점 첫번째 자리에 반올림, 소수점 첫번째 자리에 반올림, 소수점 셋째 자리에 반올림, 소수점을 기준으로 앞쪽으로 감(-2)

TRUNC : 절삭

SELECT TRUNC(4567.789), TRUNC(4567.789,0), TRUNC(4567.789,2), TRUNC(4567.789,-2) FROM DUAL;

[12] 상품 테이블의 상품 정보 가운데 100원 단위까지 버린 배송비를 상품별과 원래 배송비, 절삭한 배송비를 함께 보여주세요
SELECT PRODUCTS_NAME, TRANS_COST, TRUNC(TRANS_COST,-3) FROM PRODUCTS;



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

MOD(값1, 값2)
:값1을 값2로 나눈 나머지 값을 반환한다.
[13] EMP에서 부서번호가 10인 사원의 급여를 30으로 나눈 나머지를 사원명과 함께 출력하세요
SELECT * FROM EMP;
SELECT ENAME, MOD(SAL, 30)"30으로 나눈 나머지" FROM EMP WHERE DEPTNO='10';



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

ABS(값): 절대값을 반환
CEIL(값): 올림값을 반환
FLOOR(값): 내림값을 반환

SELECT NAME,AGE,AGE-40,ABS(AGE-40)"나이 차이" FROM MEMBER;

SELECT CEIL(123.556), FLOOR(123.556), ROUND(123.556) FROM DUAL;

SELECT POWER(2,8), SQRT(64), SIGN(-100), SIGN(100), SIGN(0) FROM DUAL;
POWER(값1,값2):거듭제곱
SQRT(값):제곱근
SIGN(값):값이 양수면 1을 반환, 음수면 -1을 반환, 0이면 0을 반환
주어진 숫자가 음수인지 양수인지 구별하고자 할 때 사용

SELECT CHR(65), ASCII('W') FROM DUAL;

SELECT SYSDATE+10 "10일 뒤", SYSDATE-10 "10일 전" FROM DUAL;

SELECT TO_CHAR(SYSTIMESTAMP -1/24,'YYYY-MM-DD HH:MI:SS')"1시간 전", TO_CHAR(SYSTIMESTAMP+3/24, 'YYYY-MM-DD HH:MI:SS')"3시간 후" FROM DUAL;

[14]EMP테이블에서 사원들이 현재까지 근무 년수가 몇 년인지 출력하세요. 단 근무 일수가 많은 사람 순으로 출력하세요
DATE-DATE:일수
SELECT * FROM EMP;
SELECT ENAME, TRUNC((SYSDATE-HIREDATE)/365) "근무년수" FROM EMP ORDER BY HIREDATE ASC;



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

[15]사원 테이블에서 사원들이 현재까지 근무일수가 몇주 몇일인지 출력하세요
SELECT ENAME, TRUNC((SYSDATE-HIREDATE)/7)"근무 주수", ROUND(MOD((SYSDATE-HIREDATE), 7)) "근무 일수" FROM EMP;



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

ADD_MONTHS(D, 값1) : 주어진 날짜(D)에 값1의 월 수를 더해 반환한다.
SELECT add_months('16/10/12', 2), add_months('16/10/31',4) from dual;

고객(Member) 테이블이 두 달의 기간을 가진 유료 회원이라는 가정하에 등록일(reg_date)을 기준으로 유료 회원인 고객의 정보(이름,등록일,만기일)를 보여주세요
select * from Member;
select NAME, REG_DATE, add_months(REG_DATE, 2)"만기일", MILEAGE from Member where MILEAGE>0;

LAST_DAY(D)
D가 포함되어 있는 월의 마지막 날짜 값을 반환
SELECT LAST_DAY('13/08/08') FROM DUAL;

SYSDATE/SYSTIMESTAMP
SYSDATE:시스템의 현재 시간을 DATE 유형으로 반환
SYSTIMESTAMP:시스템의 현재 시간을 TIMESTAMP유형으로 반환

SELECT SYSDATE, SYSTIMESTAMP FROM DUAL;

SELECT SYSDATE, TO_CHAR(SYSDATE,'YYYY-MM-DD HH:MI:SS') FROM DUAL;

SELECT TO_CHAR(SYSDATE, 'cc year-month-ddd day') from dual;

cc: 세기 / year: 연도 / month:월 / ddd:[ddd->1년의 날짜, dd->1개월 날짜, d->일주일의 날짜] / day: 요일

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

사원(emp)테이블을 select하는 예제

안녕하세요

이번 시간에는 사원(emp) 테이블을 select하는 예제 올려봅니다.

이번 예제도 쉽긴 하지만 저번 예제보다는 좀 더 활용도가 높습니다.

LIKE 연산자, ORDER BY절 등이 포함되 있으니 천천히 살펴보세요~!


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

[1]사원(emp)테이블에서 업무가 salesman이거나 president인 사원의 사번, 사원명, 업무, 급여를 보여주세요
--SALESMAN, PRESIDENT 같은 경우 원래 값이 대문자이므로 대문자로 조회해야함
select empno,ename,job,sal from emp where
job='SALESMAN' or job='PRESIDENT';



--값은 대소문자를 구분한다 upper()함수=>대문자로 바꿔줌 lower()

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

--[2]사원 테이블에서 급여가 1500이 아닌 사원의 이름,급여를 출력하세요
select ename,sal from emp where sal!=1500;
--sal<>1500



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

--[3]emp에서 급여가 2000,3000,5000인 사원의 이름, 업무, 급여 보여주세요
select ename,job,sal from emp where sal=2000 or sal=3000 or sal=5000;
--sal in(2000,3000,5000)



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

[4]emp에서 급여가 2000,3000,5000이 아닌 사원의 이름, 업무, 급여 보여주세요
select ename,job,sal from emp where sal not in(2000,3000,5000);
select ename,job,sal from emp where sal<>2000 and sal<>3000 and sal<>5000;



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

LIKE 연산자
검색 할 때 와일드 카드를 사용하여 많이 쓴다
WHERE 컬럼명 LIKE '조건';
WHERE 컬럼명 LIKE '조건%';
WHERE 컬럼명 LIKE '%조건';
WHERE 컬럼명 LIKE '%조건%';
%->와일드 카드 / 문자가 0개 이상의 문자
'_' =>1개의 문자와

SELECT * FROM STUDENT WHERE NAME LIKE '홍%';

[5]emp에서 이름 S자로 시작하는 사원의 이름,업무 보여주세요
select * from emp;
select ename,job from EMP where ENAME like 'S%';



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

[6]emp에서 이름 중 S자가 들어가는 사원의 모든 정보를 보여주세요
select * from emp where ename like '%S%';



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

[7]emp에서 이름이 D로 끝나는 사원의 이름, 급여를 보여주세요
select ename, sal from emp where ename like '%D';

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

[8]이름의 두번째에 O자가 들어가는 사람 정보를 보여주세요
select * from emp where ename like '_O%';



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

[9]이름의 끝에서 세번째에 T자가 들어가는 사람 정보를 보여주세요
select * from emp where ename like '%T__';



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

[10 emp에서 82년도에 입사한 사원의 이름,입사일을 보여주세요
select ename,hiredate from emp where hiredate like '82%';



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

날짜 포맷을 변경하자
ALTER SESSION SET NLS_DATE_FORMAT='YY/MM/DD';
ALTER SESSION SET NLS_DATE_FORMAT='YYYY-MM-DD';
ALTER SESSION SET NLS_DATE_FORMAT='DD-MON-YYYY';

[11] member에서 '강북구'에 사는 회원의 이름,주소,마일리지를 보여주세요
select name, ADDR, MILEAGE from member where addr like '%강북%';



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

[12] EMP에서 COMM이 0인 사원의 이름, JOB, 급여, COMM을 보여주세요
select ename, job, sal, comm from emp where comm=0;



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

[13] EMP에서 보너스(COMM)을 받지 않는 사원의 이름, 업무, 급여, COMM을 보여주세요
SELECT ENAME,JOB,SAL,COMM FROM EMP WHERE COMM is NULL;
SELECT ENAME,JOB,SAL,COMM FROM EMP WHERE COMM is not NULL;



null 비교는 = 로 비교하면 안된다, IS NULL 연산자로 비교한다

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

ORDER BY절
데이터를 정렬하고자 할 때 사용한다
오름차순 ASEC <= 디폴트
내림차순 DESC
ORDER BY절은 SELECT문의 제일 뒤에 위치한다.

WGHO순서 (WHERE, GROUP BY, HAVING, ORDER BY)

[14] EMP에서 입사일자 순으로 정렬하여 사번,이름,입사일을 보여주세요
select empno,ename,hiredate from emp order by hiredate desc;



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

[15] 이름을 알파벳 순으로 보여주세요
select ename from emp order by ename;
select empno,ename,hiredate, sal*12+nvl(comm,0) from emp order by 2 asc; --2번째 칼럼을 오름차순으로 보여주세요



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

[16] 연봉이 제일 많은 순서대로 가져와 보여주세요
select empno,ename,hiredate,sal*12+nvl(comm,0) from emp order by 4 desc;



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

[17] EMP에서 부서번호(DEPTNO)로 정렬한 후 부서번호가 같을 경우 급여가 많은 순으로 정렬하여 사번, 이름, 부서번호, 급여, 업무를 출력하세요
select empno, ename, deptno, sal, job from emp order by deptno, sal desc;



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

[18] 상품(PRODUCTS) 테이블에서 판매가격(OUTPUT_PRICE)이 저렴한 순서대로 상품을 정렬하여 모든 정보를 보여주세요
select * from products order by output_price;



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