package com.swift.department;

import java.sql.Connection;

import java.sql.PreparedStatement;

import java.sql.SQLException;

/*SQL语句的编写

JDBC操作MySQL数据库常用API

1.在数据库创建部门表和员工表，包含字段如下：

    部门表包含字段有：部门编号，部门名称(唯一且不能为空)

员工表包含字段有：员工编号，员工姓名(唯一且不能为空)，员工性别，员工职位，员工工资，入职日期。部门编号(外键)

2.先添加多个部门数据，再添加多条员工数据

3.编写方法接收一个员工编号和工资两个参数，方法内将指定编号的员工工资修改为新的工资。

4.编写方法查询指定职位所有员工的信息，返回List<Employee>集合。

5.编写方法查询指定姓名的员工信息，返回Employee对象。

6.编写方法根据员工姓名删除指定的员工信息。

7.编写方法查询所有姓张员工的工资并输出在控制台，输出格式如下：

    张三=10000

    张飞=20000

    …………………..

8.编写方法接收一个工资参数，方法内查询工资大于等于传入的工资的员工，返回符合条件所有员工信息List<Employee>集合。

9.编写方法查询指定部门的所有员工信息，返回List<Employee>集合*/

public class Department {

    public static void main(String[] args) throws ClassNotFoundException, SQLException {

//        createDatabaseTable();

        addData();

    }

    private static void addData() throws ClassNotFoundException, SQLException {

        Connection con=JdbcUtil.getConnection();

        PreparedStatement statement = con.prepareStatement("INSERT INTO department(did,dname) VALUES(1,'行政'),(2,'研发'),(3,'财务');");

        int row = statement.executeUpdate();

        if(row>=1) {

            System.out.println("部门数据添加成功.");

        }

        statement = con.prepareStatement("INSERT INTO employee VALUES\r\n" +

                "(1,'刘备','男','董事长',50000.00,'2002-02-02',1),\r\n" +

                "(2,'关羽','男','项目经理',30000.00,'2008-08-08',2),\r\n" +

                "(3,'张飞','男','程序员',10000.00,'2012-10-24',2);");

        row = statement.executeUpdate();

        if(row>=1) {

            System.out.println("员工数据添加成功.");

        }

    }

    private static void createDatabaseTable() throws ClassNotFoundException, SQLException {

        Connection con=JdbcUtil.getConnection();

        PreparedStatement statement = con.prepareStatement("CREATE TABLE IF NOT EXISTS department(\r\n" +

                "    did INT PRIMARY KEY ,\r\n" +

                "    dname VARCHAR(50) UNIQUE NOT NULL\r\n" +

                ");");

        int row = statement.executeUpdate();

        if(row==0) {

            System.out.println("部门表创建成功.");

        }

        statement = con.prepareStatement("CREATE TABLE IF NOT EXISTS employee(\r\n" +

                "    eid INT PRIMARY KEY ,\r\n" +

                "    NAME VARCHAR(50) UNIQUE NOT NULL,\r\n" +

                "    sex VARCHAR(2) ,\r\n" +

                "    POSITION VARCHAR(50),\r\n" +

                "    salary DECIMAL(10,2),\r\n" +

                "    entry_date DATE,\r\n" +

                "    did INT,\r\n" +

                "    CONSTRAINT fk_did FOREIGN KEY (did) REFERENCES department (did)\r\n" +

                ");");

        row = statement.executeUpdate();

        if(row==0) {

            System.out.println("员工表创建成功.");

        }

        JdbcUtil.close(con, statement);

    }

}