1. 程式人生 > >JDBC連線MySQL5.7

JDBC連線MySQL5.7

2.從下載的檔案中取出mysql-connector-java-5.1.31-bin.jar,放到工程中,並匯入路徑

方法:右擊工程名->Build Path->Configure Build Path,選擇Add External JAR… 找到mysql-connector-java-5.1.31-bin.jar所在的位置,然後將驅動包載入到專案中,
構建路徑
3.寫個例子測試一下

package testmysql;  
import java.sql.*;  
public class Test {  

    public static void main(String[] args) {  
        String driver = "com.mysql.jdbc.Driver"
; String URL = "jdbc:mysql://localhost:3306/student"; Connection con = null; try { Class.forName(driver); } catch(java.lang.ClassNotFoundException e) { System.out.println("Connect Successfull."); System.out
.println("Cant't load Driver"); } try { con=DriverManager.getConnection(URL,"root","root"); System.out.println("Connect Successfull."); } catch
(Exception e) { System.out.println("Connect fail:" + e.getMessage()); } } }

連線上資料庫之後,可以根據表中的內容進行資料庫表的查詢,首先表中要有內容,將一些資訊輸入到表中之後即可使用SQL語言進行查詢

import java.sql.*;    
public class Main {    

    public static void main(String[] args) {    
        String driver = "com.mysql.jdbc.Driver";    
        String URL = "jdbc:mysql://localhost:3306/xiaolu";    
        Connection con = null;  
        ResultSet rs = null;  
        Statement st = null;  
        String sql = "select * from student";  
        try    
        {    
            Class.forName(driver);    
        }    
        catch(java.lang.ClassNotFoundException e)    
        {    
           // System.out.println("Connect Successfull.");    
            System.out.println("Cant't load Driver");    
        }    
        try       
        {                                                                                   
            con=DriverManager.getConnection(URL,"root","root");    
            st=con.createStatement();  
            rs=st.executeQuery(sql);  
            if(rs!=null) {  
                ResultSetMetaData rsmd = rs.getMetaData();  
                int countcols = rsmd.getColumnCount();  
                for(int i=1;i<=countcols;i++) {  
                    if(i>1) System.out.print(";");  
                    System.out.print(rsmd.getColumnName(i)+" ");  
                }  
                System.out.println("");  
                while(rs.next()) {  
                    System.out.print(rs.getString("sno")+"  ");  
                    System.out.print(rs.getString("sname")+"  ");  
                    System.out.print(rs.getString("ssex")+"  ");  
                    System.out.print(rs.getString("sage")+"  ");  
                    System.out.println(rs.getString("sdept")+"  ");  
                }  
            }  
            //System.out.println("Connect Successfull.");    
            System.out.println("ok");  
            rs.close();  
            st.close();  
            con.close();  
        }     
        catch(Exception e)    
        {    
            System.out.println("Connect fail:" + e.getMessage());    
        }    
    }    
}  

另一份測試程式碼

package com.lsjckj.jdbc;

import java.sql.Connection; 
import java.sql.DriverManager; 
import java.sql.PreparedStatement; 
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;

import com.mysql.jdbc.Driver; 

/**
 * @author swayer 2014下午1:20:16
 * 
 */ 

public class JdbcUtil { 
    public static void main(String[] args) throws Exception {
        //1.建立Driver實現類的物件
        Driver driver = new com.mysql.jdbc.Driver();
        System.out.println(driver);
        //2.建立連線資料庫的內容(使用者名稱、密碼)物件
        Properties properties = new Properties();
        //3.設定資料庫地址
        String url = "jdbc:mysql://127.0.0.1:3306/bdcms";
        //4.通過驅動獲取資料庫連線物件
        Connection coon =DriverManager.getConnection(url,"root","root");
        System.out.println("Connect Successfull.");
        try {
            Statement stmt = coon.createStatement();
            String sql="select * from bd_flink";
            ResultSet rs = stmt.executeQuery(sql);

            if(rs!=null) {
                ResultSetMetaData rsmd = rs.getMetaData();
                int countcols = rsmd.getColumnCount();
                for(int i=1;i<=countcols;i++) {
                    if(i>1) System.out.print(";");
                    System.out.print(rsmd.getColumnName(i)+" ");
                }
                System.out.println("");
                while(rs.next()) {
                    System.out.print(rs.getString("flink_id")+"  ");
                    System.out.print(rs.getString("webname")+"  ");
                    System.out.print(rs.getString("logo")+"  ");
                }
            }

            System.out.println("ok");
            rs.close();
            stmt.close();
            coon.close();
        }
        catch(Exception e) {
            System.out.println("Connect fail:" + e.getMessage());
        }
    }
}