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连接操作都将以此为基础
(作者小白,不喜勿喷,小白进来,大神走开)
时间: 2024-10-21 03:58:41