JDBC (JAVA+MySQL / 연동해서 출력하기)

 

import java.sql.Connection;
import java.sql.DriverManager;

public class Test1{
    public static Connection get() {
        Connection con=null;

        try{
            String id="아이디";
            String pw="패스워드";
            String url="jdbc:mysql://localhost:호스트넘버/스키마이름";

            Class.forName("com.mysql.cj.jdbc.Driver");
            //Class 클래스로 mysql 드라이버를 로딩하는 코드 =>DriverManager에 등록됨

            con= DriverManager.getConnection(url,id,pw);
            //Connection객체를 얻음
            //con은 실제로 데이터베이스와 연결하여 작업을 수행할 수 있는 통로로 작용하는 중요한 객체 변수로 사용됨

            System.out.println("DB에 연결됐다.");
        }
        catch (Exception e){
            System.out.println("로딩실패");
        }
        return con;
    }
}

import java.sql.*;

public class Test2 {
    public static void main(String[] args) throws SQLException {

        Connection con = null; //DB와 연결하는 인터페이스
        PreparedStatement psmt=null;
        ResultSet rs=null; //sql에 대한 반환 (쿼리 실행에 대한 결과값 저장)

        try{
            String que="select *from emp";

            con=Test1.get(); // DB연결

            psmt=con.prepareStatement(que);
            rs=psmt.executeQuery();

            //select -> executeQuery()
            //DML(insert, update, delete..) -> excuteUpdate();
            while(rs.next()){
                //DB에 있는 값들을 가져옴(행 기준)
                String empno=rs.getString(1);
                String ename=rs.getString(2);
                String job=rs.getString(3);
                int mgr=rs.getInt(4);
                Date hiredate=rs.getDate(5);
                int sal=rs.getInt(6);
                int comm=rs.getInt(7);
                int deptno=rs.getInt(8);

                System.out.println(empno+" "+ename+" "+job);
            }
        }catch(Exception e){
            e.printStackTrace();
        }
        rs.close();
        psmt.close();
        con.close();

    }
}

 

---

 

테이블 2개 생성

use 스키마이름;

create table users(
userid varchar(20) primary key,
username varchar(20) not null,
password varchar(20) not null,
age int(3) not null,
email varchar(40) not null);

create table boards(
bno int primary key auto_increment,
btitle varchar(100) not null,
bcontent longtext not null,
bwriter varchar(30) not null,
bdate datetime default now(),
bfilename varchar(50) null,
bfiledata longblob null); -- binary large object

desc boards;

 

JDBC 연결하기

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;

public class Jdbc1 {
	public static void main(String[] args) throws SQLException {
		
		Connection conn=null;
		
		try {
			Class.forName("com.mysql.cj.jdbc.Driver");
			//Class클래스로 JDBC드라이버를 로딩되어지면서 DriverManager에 등록된다
			
			conn=DriverManager.getConnection(
			"jdbc:mysql://localhost:3306/스키마이름",
			"아이디",
			"비밀번호");
			//Connection객체 생성하여 데이터베이스와 연결이 이루어지도록 한다
		}catch(Exception e) {}

		conn.close();  //연결끊기
	}

}

 

MySQL 데이터베이스에 새로운 사용자 정보를 삽입

package jdbc;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;

public class jdbc1 {
    public static void main(String[] args) throws SQLException {

        Connection conn = null;

        try {
            Class.forName("com.mysql.cj.jdbc.Driver");
            //Class클래스로 JDBC드라이버를 로딩되어 지면서 DriverManager에 등록된다

            conn= DriverManager.getConnection(
                    "jdbc:mysql://localhost:3306/khw","root","0000");
            //  Connection 객체 생성하여 DB와 연결이 이루어지도록 함

            String sql="insert into users(userid,username,password,age,email)"
                        +"values(?,?,?,?,?)";

            PreparedStatement pstmt = conn.prepareStatement(sql);
            // ? : 바인드 변수 -> 매번 값이 바뀔 수 있기 때문에 미리 정해 놓지 않는다
            // setXXX (순서, 데이터)
            pstmt.setString(1, "com");
            pstmt.setString(2, "tom");
            pstmt.setString(3, "1234");
            pstmt.setInt(4, 49);
            pstmt.setString(5,"aa@naver.com");

            int r = pstmt.executeUpdate();
            //executeXXX : 쿼리문 실행되기 위해 호출하는 메소드
            System.out.println(r);

            pstmt.close();

        } catch (Exception e){}

        conn.close(); // 연결끊기

    }
}

 

MySQL 데이터베이스에 게시글을 삽입

package jdbc;

import java.io.FileInputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.Statement;

public class BoardInsert {
    public static void main(String[] args) {
        Connection conn = null;
        try {

            Class.forName("com.mysql.cj.jdbc.Driver");
            conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/khw", "root", "0000");

            String sql = "INSERT INTO boards (btitle, bcontent, bwriter, bdate, bfilename,bfiledata) "
                    + "VALUES (?, ?, ?, now(), ?, ?)";

            PreparedStatement pstmt = conn.prepareStatement(sql,
                    Statement.RETURN_GENERATED_KEYS);
//자동증가된 bno값 가져옴
            pstmt.setString(1, "금요일");
            pstmt.setString(2, "금요일입니다");
            pstmt.setString(3, "juli");
            pstmt.setString(4, "뤂");
            pstmt.setBlob(5, new FileInputStream
                    ("C:\\Users\\Kang\\Pictures/고죠사토루.jfif"));

            int r=pstmt.executeUpdate();
            System.out.println(r); //갱신된 행의 개수

            if(r==1) {
                ResultSet rs=pstmt.getGeneratedKeys(); //bno값
                if(rs.next()) {
                    int bno=rs.getInt(1);
                    System.out.println("게시글 수 "+bno);
                }
                rs.close();
            }
            pstmt.close();
            conn.close();
        }catch(Exception e) {}
    }
}

 

MySQL 데이터베이스의 게시글을 업데이트

import java.io.FileInputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;

public class BoardUpdate {
public static void main(String[] args) throws SQLException {
Connection conn = null;
try {

Class.forName("com.mysql.cj.jdbc.Driver");
conn = DriverManager.getConnection
("jdbc:mysql://localhost:3306/sjw", "root", "1234");

String sql = new StringBuilder()
.append("UPDATE boards SET ")
.append("btitle= ?, ")
.append("bcontent= ?, ")
.append("bfilename= ?, ")
.append("bfiledata= ? ")
.append("WHERE bno= ?")
.toString();

PreparedStatement pstmt=conn.prepareStatement(sql);
pstmt.setString(1, "hi");
pstmt.setString(2, "hello");
pstmt.setString(3, "루피.jpg");
pstmt.setBlob(4, new FileInputStream
("C://Users//itcamp//Desktop/짱구.jpg"));
pstmt.setInt(5,1);

int r=pstmt.executeUpdate();
System.out.println("수정된 행 개수" + r);
pstmt.close();


}catch(Exception e) {}
conn.close();
}

}

 

 

클래스를 사용하여 데이터베이스 작업을 수행/ 사용자 정보를 데이터베이스에 삽입하거나 가져오는 등의 작업 가능

package jdbc;

public class User {
    private String userid;
    private String username;
    private String password;
    private int age;
    private String  email;

    public String getUserid() {
        return userid;
    }

    public void setUserid(String userid) {
        this.userid = userid;
    }

    public String getUsername() {
        return username;
    }

    public void setUsername(String username) {
        this.username = username;
    }

    public String getPassword() {
        return password;
    }

    public void setPassword(String password) {
        this.password = password;
    }

    public int getAge() {
        return age;
    }

    public void setAge(int age) {
        this.age = age;
    }

    public String getEmail() {
        return email;
    }

    public void setEmail(String email) {
        this.email = email;
    }
    @Override
public String toString(){
        return userid+" "+username+" "+email;
}

}
// 테이블에서 User정보를 가져온 후 콘솔에 출력하기를 원함

 

 

JDBC를 사용하여 MySQL 데이터베이스에서 사용자 정보를 선택하고 출력

package jdbc;

import java.sql.*;

public class UserSelect {
    public static void main(String[] args) throws SQLException {
        // 테이블에서 User정보를 가져온 후 콘솔에 출력하기를 원함


        Connection conn = null;

        try {
            Class.forName("com.mysql.cj.jdbc.Driver");
            //Class클래스로 JDBC드라이버를 로딩되어 지면서 DriverManager에 등록된다

            conn = DriverManager.getConnection(
                    "jdbc:mysql://localhost:3306/khw", "root", "0000");
            //  Connection 객체 생성하여 DB와 연결이 이루어지도록 함

            String sql = "select *from users where userid=?";

            PreparedStatement pstmt = conn.prepareStatement(sql);
            pstmt.setString(1, "com");

            //ResultSet : 반환값이 여러 개의 행인 경우에 쉽게 처리할 수 있게 설계된 클래스
            ResultSet rs = pstmt.executeQuery(); //정보들 가져옴
            if (rs.next()) {
                User u = new User();
                u.setUserid(rs.getString(1));
                //테이블에 저장되어 있는 userid값을 가져와서 User클래승 userid라는 필드에 세팅
                u.setUsername(rs.getString("username"));
                u.setPassword(rs.getString(3));
                u.setAge(rs.getInt(4));
                u.setEmail(rs.getString(5));

                System.out.println(u);
            }
            rs.close();
            pstmt.close();
        } catch (Exception e) {
        }
        conn.close();
    }
}

 

 

게시글 정보를 표현하는 Board 클래스를 정의

package jdbc;

import java.sql.Blob;
import java.util.Date;


public class Board {

    private int bno;
    private String btitle;
    private String bcontent;
    private String bwriter;
    private Date bdate;
    private String bfilename;
    private Blob bfiledata;

    @Override
    public String toString() {
        return btitle+" "+bwriter;
    }


    public int getBno() {
        return bno;
    }

    public void setBno(int bno) {
        this.bno = bno;
    }

    public String getBtitle() {
        return btitle;
    }

    public void setBtitle(String btitle) {
        this.btitle = btitle;
    }

    public String getBcontent() {
        return bcontent;
    }

    public void setBcontent(String bcontent) {
        this.bcontent = bcontent;
    }

    public String getBwriter() {
        return bwriter;
    }

    public void setBwriter(String bwriter) {
        this.bwriter = bwriter;
    }

    public Date getBdate() {
        return bdate;
    }

    public void setBdate(Date bdate) {
        this.bdate = bdate;
    }

    public String getBfilename() {
        return bfilename;
    }

    public void setBfilename(String bfilename) {
        this.bfilename = bfilename;
    }

    public Blob getBfiledata() {
        return bfiledata;
    }

    public void setBfiledata(Blob bfiledata) {
        this.bfiledata = bfiledata;
    }


}

 

 

JDBC를 사용하여 MySQL 데이터베이스에서 게시글 정보를 선택하고 출력

package jdbc;

import java.io.FileOutputStream;
import java.io.InputStream;
import java.io.OutputStream;
import java.sql.*;

public class BoardSelect {
    public static void main(String[] args) throws SQLException {

        Connection conn = null;
        try {

            Class.forName("com.mysql.cj.jdbc.Driver");
            conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/khw", "root", "0000");

            String sql = "select *from boards where bno=?";
            PreparedStatement pstmt = conn.prepareStatement(sql);
            pstmt.setInt(1, 2);
            //bno값이 2인 테이블 정보 다 가져옴

            ResultSet rs=pstmt.executeQuery();
            while(rs.next()) {
                Board bo=new Board();
                bo.setBno(rs.getInt(1));
                bo.setBtitle(rs.getString("btitle"));
                bo.setBcontent(rs.getString(3));
                bo.setBwriter(rs.getString(4));
                bo.setBdate(rs.getDate(5));
                bo.setBfilename(rs.getString(6));
                bo.setBfiledata(rs.getBlob(7));

                System.out.println(bo);


                Blob b=bo.getBfiledata();
                if(b!=null) { //이미지 있음
                    InputStream is= b.getBinaryStream();
                    OutputStream os=new FileOutputStream("C:\\Users\\Kang"+ bo.getBfilename());

                    is.transferTo(os);
                    os.flush();
                    os.close();
                    is.close();
                }

            }
            rs.close();
            pstmt.close();
        }catch(Exception e) {}
        conn.close();
    }
    }