JDBC

package study.jdbc;

import com.mysql.jdbc.Driver;

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

/**
 * 1、导入驱动jar包
 * 复制相应的jar包到项目中
 * 将jar所在的目录添加为库（Iltellij IDE 选择jar所在目录右键添加为库）
 *
 * 2、注册驱动
 *  DriverManager：
 *      驱动管理对象
 *      功能：
 *          1、注册驱动
 *          2、获取数据库连接
 *  Connection：
 *      数据库连接对象
 *      功能：
 *          1、获取执行sql的对象
 *              * Statement ceateStatement()
 *              * PreparedStatement prepareStatement(string sql)
 *          2、管理事务
 *              * 开启事务：setAutoCommit(boolean autoCommit) 设置 false 开启事务
 *              * 提交事务：commit()
 *              * 回滚事务：rollback()
 *  Statement：
 *      用于执行静态SQL语句并返回其生成的结果的对象
 *      功能：
 *          1、执行sql语句
 *              * execute(string sql) 执行任意的SQL语句
 *              * int executeUpdate(string sql) 执行 DML（insert、update、delete） 语句、DDL（create、alter、drop）语句 ，该方法返值是影响行数
 *              * ResultSet executeQuery(string sql) 执行 DQL（select）语句
 *  ResultSet：
 *      结果集对象 表示数据库结果集的数据表，通常通过执行查询数据库的语句生成
 *
 */
public class Jdbc {
    public static void main(String[] args)  {
        /*
        //注册驱动
        Class.forName("com.mysql.jdbc.Driver");
        //获取数据库连接对象
        Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/test", "root", "root");
        //定义sql语句
        String sql = "select * from emp";
        //获取SQL对象 Statement
        Statement stmt = conn.createStatement();
        //执行语句
        ResultSet result = stmt.executeQuery(sql);
        System.out.println(result);
        //释放资源
        stmt.close();*/

        Connection conn = null;
        Statement stmt = null;
        ResultSet res = null;
        //注册驱动
        try {
            Class.forName("com.mysql.jdbc.Driver");
            //获取Connection连接对象
            conn = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/test", "root", "root");
            //获取执行SQL对象
            stmt = conn.createStatement();

            //定义SQL
            //增
            String insert = "insert into emp(id,ename,job_id,mgr,joindate,salary,bonus,dept_id) values(1,'乔峰',2,1010,'2001-09-28',29750,1000,20)";
            //删
            String delete = "delete from emp where id = 1";
            //改
            String update = "update emp set id = 2 where id = 1001";
            //查
            String select = "select * from emp";

            //执行语句
            /*int i1 = stmt.executeUpdate(insert);//影响行数
            int i2 = stmt.executeUpdate(delete);//影响行数
            int i3 = stmt.executeUpdate(update);//影响行数
            System.out.println(i1);
            System.out.println(i2);
            System.out.println(i3);*/

            //执行查询语句
            //获取单个数据
            res = stmt.executeQuery(select);
            /*res.next();//指针向下移动一行 返回false表示已经到最后
            System.out.println(res.getInt(1));
            System.out.println(res.getString("ename"));
            System.out.println(res.getInt("job_id"));*/


            //遍历 将查询结果集封装为对象
            Emp emp = null;
            List<Emp> list = new ArrayList<>();
            while (res.next()){
                emp = new Emp();
                emp.setId(res.getInt("id"));
                emp.setEname(res.getString("ename"));
                emp.setId(res.getInt("job_id"));
                emp.setMgr(res.getInt("mgr"));
                emp.setJoindate(res.getDate("joindate"));
                emp.setSalary(res.getDouble("salary"));
                emp.setBonus(res.getDouble("bonus"));
                emp.setDept_id(res.getInt("dept_id"));

                list.add(emp);

            }

            Iterator<Emp> it = list.iterator();
            while (it.hasNext()) {
                System.out.println(it.next());
            }

        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException throwables) {
            throwables.printStackTrace();
        }finally {
            if (conn != null) {
                try {
                    conn.close();
                } catch (SQLException throwables) {
                    throwables.printStackTrace();
                }
            }

            if (stmt != null) {
                try {
                    stmt.close();
                } catch (SQLException throwables) {
                    throwables.printStackTrace();
                }
            }

            if (res != null) {
                try {
                    res.close();
                } catch (SQLException throwables) {
                    throwables.printStackTrace();
                }
            }
        }

    }

}