MySQL 데이터베이스에 대한 Java 연결 - 단계 및 코드 포함

도구: eclipse

　MySQL5.6

MySQL 연결 드라이버: mysql-connector-java-5.1.27 .jar

드라이버 로드:

1. 아래 그림과 같이 프로젝트 디렉터리에 lib 폴더를 만들고 다운로드한 JDBC를 해당 폴더에 넣습니다.

　2. 프로젝트 이름을 마우스 오른쪽 버튼으로 클릭하고 Java 빌드 경로의 Libraries 탭에서 Add JARs...를 선택한 다음 아래와 같이 방금 추가한 JDBC를 선택합니다.

데이터 패키지 준비:

데이터베이스 sqltestdb에 다음 데이터 테이블 emp를 생성합니다.

CREATE TABLE emp(
   empno            INT(4)          PRIMARY KEY,
   ename            VARCHAR(10),
   job              VARCHAR(9),
   hiredate         DATE,
   sal              FLOAT(7,2)
) ;

로그인 후 복사

데이터 추가:

데이터베이스 접속 및 데이터 읽기:

데이터베이스 이름: sqltestdb

데이터 패키지 이름: emp

포트 번호: 3306

사용자 이름: root

비밀번호: root

 1 package sqldemo; 2  3 import java.sql.Connection; 4 import java.sql.DriverManager; 5 import java.sql.ResultSet; 6 import java.sql.SQLException; 7 import java.sql.Statement; 8  9 public class main {10 11     public static void main(String[] args) {12         //声明Connection对象13         Connection con;14         //驱动程序名15         String driver = "com.mysql.jdbc.Driver";16         //URL指向要访问的数据库名mydata17         String url = "jdbc:mysql://localhost:3306/sqltestdb";18         //MySQL配置时的用户名19         String user = "root";20         //MySQL配置时的密码21         String password = "123456";22         //遍历查询结果集23         try {24             //加载驱动程序25             Class.forName(driver);26             //1.getConnection()方法，连接MySQL数据库！！27             con = DriverManager.getConnection(url,user,password);28             if(!con.isClosed())29                 System.out.println("Succeeded connecting to the Database!");30             //2.创建statement类对象，用来执行SQL语句！！31             Statement statement = con.createStatement();32             //要执行的SQL语句33             String sql = "select * from emp";34             //3.ResultSet类，用来存放获取的结果集！！35             ResultSet rs = statement.executeQuery(sql);36             System.out.println("-----------------");37             System.out.println("执行结果如下所示:");  
38             System.out.println("-----------------");  
39             System.out.println("姓名" + "\t" + "职称");  
40             System.out.println("-----------------");  
41              42             String job = null;43             String id = null;44             while(rs.next()){45                 //获取stuname这列数据46                 job = rs.getString("job");47                 //获取stuid这列数据48                 id = rs.getString("ename");49 50                 //输出结果51                 System.out.println(id + "\t" + job);52             }53             rs.close();54             con.close();55         } catch(ClassNotFoundException e) {   
56             //数据库驱动类异常处理57             System.out.println("Sorry,can`t find the Driver!");   
58             e.printStackTrace();   
59             } catch(SQLException e) {60             //数据库连接失败异常处理61             e.printStackTrace();  
62             }catch (Exception e) {63             // TODO: handle exception64             e.printStackTrace();65         }finally{66             System.out.println("数据库数据成功获取！！");67         }68     }69 70 }

로그인 후 복사

Java는 MySQL 데이터베이스에 연결됩니다(단계 및 코드 포함).

실행 결과:

Succeeded connecting to the Database!
-----------------
执行结果如下所示:
-----------------
姓名  职称
-----------------
李兴华 经理
张三  总监
王五  厂长
齐秦  书记
张刚  组长
曹操  财务
李四  总裁
数据库数据成功获取！！

로그인 후 복사

추가, 삭제 및 데이터 수정:

데이터 추가:

String name;
String id;
  
PreparedStatement psql;
ResultSet res;
//预处理添加数据，其中有两个参数--“？”
psql = con.prepareStatement("insert into emp (empno,ename,job,hiredate,sal) "
        + "values(?,?,?,?,?)");
psql.setInt(1, 3212);              //设置参数1，创建id为3212的数据
psql.setString(2, "王刚");      //设置参数2，name 为王刚
psql.setString(3, "总裁");
 
DateFormat dateFormat2 = new SimpleDateFormat("yyyy-MM-dd");
Date myDate2 = dateFormat2.parse("2010-09-13");
psql.setDate(4,new java.sql.Date(myDate2.getTime()));
psql.setFloat(5, (float) 2000.3);
psql.executeUpdate();           //执行更新

로그인 후 복사

실행 결과:

데이터 업데이트:

　PreparedStatement psql;
//预处理更新（修改）数据，将王刚的sal改为5000.0
psql = con.prepareStatement("update emp set sal = ? where ename = ?");
psql.setFloat(1,(float) 5000.0);      
psql.setString(2,"王刚");             
psql.executeUpdate();

로그인 후 복사

결과 변경:

데이터 삭제:

PreparedStatement psql;
//预处理删除数据
psql = con.prepareStatement("delete from emp where sal > ?");
psql.setFloat(1, 4500);
psql.executeUpdate();
psql.close();

로그인 후 복사

결과 삭제: