java 調用mysql實例

java 調用mysql實例：

package com.tanglei.test1;

import java.sql.*;

public class Testsql{

public static void main(String []args){

Mysql mysql=new Mysql();

}

}

class Mysql{

// MySQL的JDBC URL編寫方式：jdbc:mysql://主機名稱：連接端口/數據庫的名稱?參數=值

    // 避免中文亂碼要指定useUnicode和characterEncoding

    // 執行數據庫操作之前要在數據庫管理系統上創建一個數據庫，名字自己定，

    // 下面語句之前就要先創建javademo數據庫

Connection cnn=null;

String sql;

String url="jdbc:mysql://localhost:3306/test?useSSL=false";

public Mysql(){

try{

// 之所以要使用下面這條語句，是因為要使用MySQL的驅動，所以我們要把它驅動起來，

       // 可以通過Class.forName把它加載進去，也可以通過初始化來驅動起來

//1.添加驅動

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

//2.建立連接

// 一個Connection代表一個數據庫連接

cnn=DriverManager.getConnection(url,"tester","pass1234");

cnn.setAutoCommit(false);

//3.創建statement

// Statement里面帶有很多方法，比如executeUpdate可以實現插入，更新和刪除等

Statement stmt=cnn.createStatement();

sql="create table if not exists student(No varchar(20),Name varchar(20),primary key(No))";

int res=stmt.executeUpdate(sql);

cnn.commit();

// System.out.println(res);

if(res!=-1){

System.out.println("數據庫創建成功！");

sql="insert into student (No,Name)values ('S001','Ray')";

stmt.executeUpdate(sql);

sql="insert into student (No,Name)values ('S002','Swead')";

stmt.executeUpdate(sql);

sql="insert into student (No,Name)values ('S003','Deny')";

stmt.executeUpdate(sql);

sql="select * from student";

ResultSet rs=stmt.executeQuery(sql);

System.out.println("學號\t姓名");

while (rs.next()){

System.out.println(rs.getString(1)+"\t"+rs.getString(2));

}

sql="drop table student";

stmt.executeUpdate(sql);

}

}catch(Exception e){

e.printStackTrace();

try{

cnn.rollback();

}catch (SQLException e1){

e1.printStackTrace();

}

}finally{

try{

cnn.close();

}catch(SQLException e){

e.printStackTrace();

}

}

}

}