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