[大数据]JDBC连接mysql数据库

JDBC连接mysql数据库

JDBC:使用java语言操作关系数据库的一套API。是一套标准接口，可以操作不同的关系型数据库。

先复习一下，在idea里面输出hello。

public static void main(String[] args) {//使用快捷键 psvm
    System.out.println("hello world");//使用快捷键 sout
}

下面是完整的连接一个数据库，并且修改数据库数据表信息的代码。一共七步。

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.Statement;

public class jdbc {
    public static void main(String[] args) throws Exception {
        //1.注册驱动
        Class.forName("com.mysql.jdbc.Driver");
        //2.获取连接
        String url="jdbc:mysql://127.0.0.1:3306/test";//这里的test是我的一个数据库的名称
        String username="你的用户名称";
        String password="你的密码";
        Connection conn= DriverManager.getConnection(url,username,password);
        //3.定义SQL语句
        //这里我是修改test数据库中tb_user数据表中的信息，将id为3的那一列密码修改为asdf
        String sql="update tb_user set password='asdf' where id=3";
        //4.获取执行SQL对象
        Statement sta=conn.createStatement();
        //5.执行SQL
        int count=sta.executeUpdate(sql); //count是指受影响的条数，也就是改动的条数
        // 6.处理返回结果
        if(count>0){
            System.out.println("执行成功！");
        }
        else {
            System.out.println("执行失败！");
        }
        //7.释放资源，按照顺序释放
        sta.close();
        conn.close();
    }
}

下面是改之前和改之后的变化，看id为3的密码已经变了，说明我们成功了

方法解释

DriverManager（驱动管理类）:注册驱动，获取数据库连接

Connection（数据库连接对象）：获取执行SQL对象，管理事务

Statement：执行SQL语句

ResultSet(结果集对象）：封装DQL查询语句的结果,获取查询结果

这里前面和上一个一样，只不过3,4,5,6,7不一样。

//3.定义sql
String sql="select * from tb_user";
//4.获取statement对象
Statement sta=conn.createStatement();
//5.执行sql
ResultSet resu=sta.executeQuery(sql);
//6.处理结果，遍历resu里面的所有数据
    //光标向下一行，判断当前行是否有数据
while(resu.next()){
    int id=resu.getInt(1);
    String name=resu.getString(2);
    String pasd =resu.getString(3);
    System.out.println(id);
    System.out.println(name);
    System.out.println(pasd);
    System.out.println("----------");
}
//7.释放资源
resu.close();
sta.close();
conn.close();

输出结果如下

练习小案例

下面把这个练习一下，使用这个方法，把tb_user里面的东西保存在arraylist集合里面。这个和前面一样，中间部分修改。

//3.定义sql
String sql="select * from tb_user";
//4.获取statement对象
Statement sta=conn.createStatement();
//5.执行sql
ResultSet resu=sta.executeQuery(sql);
//创建集合
List<tb_user> list=new ArrayList<>();
//6.处理结果，遍历resu里面的所有数据
    //光标向下一行，判断当前行是否有数据
while(resu.next()){
    tb_user tbu=new tb_user();//创建对象
    int id=resu.getInt(1);
    String name=resu.getString(2);
    String pasd =resu.getString(3);

    //把数据放入集合
    tbu.setId(id);
    tbu.setName(name);
    tbu.setPassword(pasd);

    list.add(tbu);//放入集合
}

System.out.println(list);//打印数据
//7.释放资源
resu.close();
sta.close();
conn.close();

新建的java类，存放一些方法，好供主函数使用

public class tb_user {
    private int id;
    private String name;
    private String password;//使用alt+insert快捷键添加

    public int getId() {
        return id;
    }

    public void setId(int id) {
        this.id = id;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public String getPassword() {
        return password;
    }

    public void setPassword(String password) {
        this.password = password;
    }

    @Override
    public String toString() {
        return "tb_user{" +
                "id=" + id +
                ", name='" + name + '\'' +
                ", password='" + password + '\'' +
                '}';
    }
}

┏(＾0＾)┛