1.現在MySQL中創建一個表
2.首先創建一個類
//導入的包
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
public class DBTil { }
3.然后實例化各個對象
1 //username和password是連接數據庫的用戶名和密碼 2 private static String username = "123"; 3 private static String password = "12345"; 4 //連接MySQL的地址 5 private static String url = "jdbc:MySql://localhost:3306/mydb"; 6 //連接MySQL的驅動 7 private static String dirver = "com.mysql.jdbc.Driver"; 8 //創建建立連接時的對象 9 static Connection conn = null; 10 //創建PreparedStatement實例,用以執行sql語句 11 static PreparedStatement preparedStatement = null; 12 //結果集對象 13 static ResultSet rs = null;
4.接着寫查詢表方法
1 //參看表 2 public static void comtrue(){ 3 String sql = "select * from user"; 4 try { 5 Class.forName(dirver); 6 conn = DriverManager.getConnection(url,username,password); 7 preparedStatement = conn.prepareStatement(sql); 8 rs = preparedStatement.executeQuery(); 9 while(rs.next()){ 10 System.out.println(rs.getString(4)+" "+rs.getString(3)+" "+rs.getString(2)+" "+rs.getString(1)); 11 } 12 System.out.println(); 13 close(rs, conn, preparedStatement); 14 15 } catch (Exception e) { 16 e.printStackTrace(); 17 } 18 }
5.看控制台下輸出的結果:
6.接着寫添加的方法:
1 //添加 2 public static void add(){ 3 String sql = "insert into user(id,username,age,sex) value(?,?,?,?)"; 4 try { 5 int result = 0; 6 Class.forName(dirver); 7 conn = DriverManager.getConnection(url,username,password); 8 preparedStatement = conn.prepareStatement(sql); 9 preparedStatement.setInt(1, 5); 10 preparedStatement.setString(2, "小明"); 11 preparedStatement.setInt(3, 10); 12 preparedStatement.setString(4, "男"); 13 result = preparedStatement.executeUpdate(); 14 System.out.println("插入成功"); 15 close(rs, conn, preparedStatement); 16 } catch (Exception e) { 17 e.printStackTrace(); 18 } 19 }
7.在原來表的基礎上添加id為5的一行數據,看結果:
看添加成功了!
8.后面刪除再實現下:
1 //刪除 2 public static void delete(){ 3 String sql = "delete from user where id = 4"; 4 try { 5 Class.forName(dirver); 6 conn = DriverManager.getConnection(url,username,password); 7 preparedStatement = conn.prepareStatement(sql); 8 preparedStatement.executeUpdate(); 9 System.out.println("刪除成功!"); 10 } catch (Exception e) { 11 e.printStackTrace(); 12 } 13 }
看結果:
刪除成功! 男 20 張三 1 女 30 李四 2 男 40 Mike 3 男 10 小明 5
9.修改實現方法:
1 //修改 2 public static void alter(){ 3 String sql = "update user set username='小紅'where id = 4"; 4 5 try { 6 Class.forName(dirver); 7 conn = DriverManager.getConnection(url,username,password); 8 preparedStatement = conn.prepareStatement(sql); 9 preparedStatement.executeUpdate(); 10 } catch (Exception e) { 11 // TODO Auto-generated catch block 12 e.printStackTrace(); 13 } 14 }
看結果:
男 20 張三 1 女 30 李四 2 男 40 Mike 3 男 10 小紅 5
改成小紅了!
10.如果想查看某行數據:
//查詢,以查詢第一行數據為例
1 //查詢 2 public static void inquire(){ 3 String sql = "select * from user limit 0 , 1"; 4 try { 5 Class.forName(dirver); 6 conn = DriverManager.getConnection(url,username,password); 7 preparedStatement = conn.prepareStatement(sql); 8 rs = preparedStatement.executeQuery(); 9 while (rs.next()) { 10 System.out.println( 11 rs.getString(1) 12 +rs.getString(2) 13 +rs.getString(3) 14 +rs.getString(4)); 15 } 16 } catch (Exception e) { 17 // TODO: handle exception 18 } 19 }
執行結果:
1張三20男
11.測試方法:
1 //測試 2 public static void main(String[] args) { 3 /*delete();*/ 4 /* add(); 5 alter();*/ 6 /*inquire();*/ 7 /*comtrue();*/ 8 } 9 10 }
12.小結:
通過控制台運行測試來實現簡單的jdbc連接,增刪改查操作,作為一個初學者,我覺得這樣的測試很有必要,以后的jdbc連接操作都將以此為基礎