JDBC

1、使用JDBC连接MySQL数据库中student表的数据。

package com.up.jdbc;

import java.sql.*;
import java.util.ArrayList;
import java.util.List;

public class Test01 {
    public static void main(String[] args) {

        List<Student> list=findAll(); //使用List集合接收数据库中的数据。
        for (Student student:list
             ) {
            System.out.println("编号："+student.getId()+"  姓名："+student.getName());
        }
        //只是将数据库的内容用对象封装起来，比较方便操作。
    }

    private static List<Student> findAll() {
        Statement statement=null; //Statement用于执行静态的sql语句
        Connection con=null; //Connection表示java程序和数据库的连接对象
        try {
        // 1、加载驱动
            Class.forName("com.mysql.jdbc.Driver");

        //2、获取连接                               此处我的端口是3307，一般默认3306。  test是我的数据库名
            String sqlUrl="jdbc:mysql://127.0.0.1:3307/test?useunicode=true&characterEncoding=utf8";
            //Driver表示java驱动程序接口
            con=DriverManager.getConnection(sqlUrl,"root","");   //root是用户名，我的没设置密码，空字符串是密码

        //3、创建状态,不带预编译
            statement=con.createStatement();

        //4、执行sql
            String sql="select * from student";
            //ResultSet用于封装查询出来的数据
            ResultSet set=statement.executeQuery(sql);
            //创建List集合
            List<Student> list=new ArrayList<>();
            Student student=null;

        //5、获取结果集的内容
            while(set.next()){
                //第1种、根据列字段索引,将数据库中的数据直接输出
                //System.out.println(set.getInt(1)+"   "+set.getString(2));
                //第2种、根据字段名
                //System.out.println(set.getInt("id")+"   "+set.getString("name"));
                student=new Student();//第3种、用List集合和Student类接收数据库中数据
                student.setId(set.getInt("id"));
                student.setName(set.getString("name"));

                list.add(student); 
            }
            return list; //如果查询到，就返回List集合中的内容。

        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        }catch(SQLException e){
            e.printStackTrace();
        }finally{
            try{
               // 6、关闭连接
                statement.close();
                con.close();

            }catch(SQLException e){
                e.printStackTrace();
            }
        }
        return null;//如果没有查询到，就返回null。
    }
}
    

创建Student类，去封装属性id和name。

package com.up.jdbc;

public class Student {
    private int id;
    private String name;

    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;
    }
}

执行结果：

 2、对数据进行增删改查

①删除

package day0829;

import org.junit.After;
import org.junit.Before;
import org.junit.Test;

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

public class Test02 {

    Statement statement=null;
    Connection connection=null;

    @Before
    public void before(){
        try{
            //1、加载驱动
            Class.forName("com.mysql.jdbc.Driver");

            //2、获取连接
            String sqlUrl="jdbc:mysql://127.0.0.1:3307/test?useunicode=true&characterEncoding=utf8";
            connection=DriverManager.getConnection(sqlUrl);

            //创建状态
            statement=connection.createStatement();
        }catch (ClassNotFoundException e){
            e.printStackTrace();
        }catch(SQLException e){
            e.printStackTrace();
        }

    }
    //①删除
    @Test
    public void delete(){
        String sql="delete from student where id=2";
        try {
            int result=statement.executeUpdate(sql);
            System.out.println(result>0?"删除成功":"删除失败");
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

删除结果：

②修改

//②修改
@Test
    public void update(){
        String sql="update student set name='古天乐' where id=1";
        try {
            int result=statement.executeUpdate(sql);
            System.out.println(result>0?"修改成功":"修改失败");
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

执行结果：

③添加

//添加
    @Test
    public void insert(){
        String sql="insert into student(name) values('渣渣辉')";
        try {
            int result=statement.executeUpdate(sql);
            System.out.println(result>0?"添加成功":"添加失败");
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

执行结果：