package cn.bruce.MySql;

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

public class ConAndinsert {

    public static void main(String[] args) {
        // 标准格式，将所有变量预先定义好
        String url;
        String username;
        String password;
        String sql;
        String jdbcname;
        Connection con = null;
        username = "root";
        password = "jinqi1986";
        // 下面两个URL都可以
        // url =
        // "jdbc:mysql://localhost:3306/test?characterEncoding=utf8&useSSL=false&serverTimezone=UTC&rewriteBatchedStatements=true";
        url = "jdbc:mysql://localhost:3306/mytrain?useSSL=false&serverTimezone=CTT";
        jdbcname = "com.mysql.cj.jdbc.Driver";
        // 加载驱动
        try
        {
            Class.forName(jdbcname);
            System.out.println("加载驱动成功！");
        } catch (Exception e)
        {
            System.out.println("加载驱动失败！");
        }
        // 连接数据库
        try
        {
            con = DriverManager.getConnection(url, username, password);
            System.out.println("连接数据库成功！");
        } catch (Exception e)
        {
            System.out.println("连接数据库失败！");
        }
        // 定义执行者对象
        Statement sa = null;
        // 上面这些都是一模一样的，套用就行
        // 执行sql插入语句
        try
        {
            sql = "insert into test (zname,zprice,zdesc) values (‘投影仪‘,333,‘Carton‘);";
            sa = con.createStatement();
            int row = sa.executeUpdate(sql);// 使用的是update，返回的是int类型
            System.out.println("修改数据" + row + "条成功！");
        } catch (Exception e)
        {
            e.printStackTrace();
        }
        // 执行sql查询语句
        try
        {
            sql = "select * from test;";
            sa = con.createStatement();
            ResultSet rs = sa.executeQuery(sql);// 使用的是query，返回的是结果集类型
            while (rs.next())// 循环结果集，当为真时，打印字段
            {
                System.out.println(rs.getString("zname"));// 按标题名称打印
            }
        } catch (Exception e)
        {
            e.printStackTrace();
        } finally
        {// 当SQL操作结束时，都关闭数据库连接
            try
            {
                con.close();
                System.out.println("数据库连接关闭成功！");
            } catch (Exception e2)
            {
                e2.printStackTrace();
            }
        }
    }

}