首页 > 代码库 > JDBC小结

JDBC小结

2024-11-05 21:20:40   211人阅读

  • JDBC(java数据连接)是一种用于执行SQL语句的Java API.
  • JDBC是Java访问数据库的标准规范,可以为不同的关系类型数据库提供统一的访问,它由一组用Java语言编写的接口和类组成.
  • MySQL的驱动mysql-connector-java-5.1.37-bin.jar
  • JDBC原理
    • Java提供访问数据库规范称为JDBC,而生产商提供规范实现类称为驱动.
    • JDBC是接口,驱动是接口的实现,没有驱动将无法完成数据库的连接,从而不能操作数据库
  • 开发步骤
    • 准备MySQL数据库驱动包mysql-connector-java-5.1.37-bin.jar
    • 导入驱动jar包
    • 注册驱动Class.forName("com.mysql.jdbc.Driver");
    • 获取连接Connection con=DriveManager.getConnection("jdbc:mysql://localhost:3306/mydb","root","root");
      • url需要连接数据库的位置(网址)

        mysql的url:jdbc:mysql://localhost:3306/mydb

        由三部分组成,每个部分中间使用冒号分隔

        第一部分是jdbc,这是固定的;

        第二部分是数据库的名称,那么连接mysql数据库,第二部分当然是mysql了;

        第三部分由数据库厂商规定的,我们需要了解每个数据库厂商的要求,mysql的第三部分分别由数据库服务器的IP地址（localhost）、端口号（3306），以及DATABASE名称(mydb) 组成;

        • user用户名
        • passwrod密码
    • 创建SQL的运输器,准备SQL语句,把SQL语句运输到MySQL的服务器端
      • String sql = "某SQL语句";
      • 获取Statement语句执行平台：Statement st = con.createStatement();
    • 结果集对象

      ResultSet rs=st.executeQuery(sql);

    • 获得指定列数据

      while(rs.next()){

      System.out.println(rs.getInt("name"));

      }

    • 关闭资源
      • Statement类中有close()
      • Connection类中有close()
      • ResultSet类中有close()
  • 增删改查代码示例

public static Connection getConnection() throws Exception {

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

String url = "jdbc:mysql://localhost:3306/mydb1";

return DriverManager.getConnection(url, "root", "123");

}

//增

@Test

public void insert() throws Exception {

Connection con = getConnection();

Statement stmt = con.createStatement();

String sql = "insert into user values(‘zhangSan‘, ‘123‘)";

stmt.executeUpdate(sql);

System.out.println("插入成功！");

}

//改

@Test

public void update() throws Exception {

Connection con = getConnection();

Statement stmt = con.createStatement();

String sql = "update user set password=‘456‘ where username=‘zhangSan‘";

stmt.executeUpdate(sql);

System.out.println("修改成功！");

}

//删

@Test

public void delete() throws Exception {

Connection con = getConnection();

Statement stmt = con.createStatement();

String sql = "delete from user where username=‘zhangSan‘";

stmt.executeUpdate(sql);

System.out.println("删除成功！");

}

//查

@Test

public void query() throws Exception {

Connection con = getConnection();

Statement stmt = con.createStatement();

String sql = "select * from user";

ResultSet rs = stmt.executeQuery(sql);

while(rs.next()) {

String username = rs.getString(1);

String password = rs.getString(2);

System.out.println(username + ", " + password);

}

}

 

JDBC小结


联系
我们