java连接Mysql数据库详细代码

//sqlsevermysql数据库连接代码
import java.sql.*;
import java.util.Scanner;

public class 数据库的连接操作 {
    public static void main(String[] args) throws Exception {

        Scanner sc=new Scanner(System.in);

//数据的传输：
        System.out.println("输入序号");
        String a=sc.nextLine();
        System.out.println("输入国家");
        String a1=sc.next();


try {
    String sql="INSERT c2 VALUES("  +a+  " ,""+a1+""); ";
    int i = Dao.daoZSG(sql); //存储到数据库里面
    System.out.println(i==1?"保存成功":"保存失败");
}
catch (Exception e)
{
    System.out.println("数据库保存失败!");
}


//数据库遍历操作
        String sql="SELECt *from c2; ";
        ResultSet r = Dao.daoFROM(sql);//获取数据库存储的值
        while (r.next())//迭代器遍历
        {
            String string = r.getString(1);//获取位置上第一个值
            String string1 = r.getString(2);//获取位置上第2歌值
            System.out.println("序号为："+string+"     国家为："+string1);
        }


    }
}




class Dao //数据库层
{

    static Statement daoConnection() throws SQLException {
        Connection conn;
        Statement stmt=null;
        try
        {
            Driver driver=new com.mysql.cj.jdbc.Driver(); //最后应该Driver最后导入一下
            DriverManager.registerDriver(driver);

            String url="jdbc:mysql://127.0.0.1:3306/text";//数据库名text
            String user="root";//账号
            String password="root";//密码
            conn=DriverManager.getConnection(url,user,password);//传输字符串语句
            stmt=conn.createStatement();

        }
        catch (Exception e)
        {

            throw new SQLException("数据库连接失败!"); //如果连接失败直接抛出异常结束运行
        }

        return stmt;//传输过去我的值
    }


    static int daoZSG(String sql)  //添加修改删除 封装起来上面直接调用就可以了
    {
        int a=-1;
        try
        {
             a=daoConnection().executeUpdate(sql);//吧sql语句放进去
            daoConnection().close();//关闭数据库
        }
        catch (Exception e)
        {
            System.out.println("数据库连接失败");
        }

        return a;//返回是否成功 1为成功 -1为不成功
    }


    static ResultSet daoFROM(String sql)  //查
    {
        ResultSet r=null;
        try
        {
            r= daoConnection().executeQuery(sql);//获取数据库存储的值
            daoConnection().close();//关闭数据库
        }
        catch (Exception e)
        {
            System.out.println("数据库查找异常");
        }

        return  r;//返回获取到的值
    }



}