java数据库 JDBC操作MySQL数据库常用API 部门表…

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