实现功能
1.登录验证
2.添加部门，查询部门，删除部门，更新部门
3.重复使用，任意退出
package com.bjpowernode.test;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.Scanner;
public class TestMain {
public static void main(String[] args)throws Exception {
//读取用户在控制输入请求
Scanner request = new Scanner(System.in);
int flag = 0;
//sql命令
String sql_1="insert into dept(deptno,dname,loc) values(?,?,?)";
String sql_2="select * from dept";
String sql_3="delete from dept where deptno=?";
String sql_4="update dept set dname=?,loc=? where deptNo=?";
String sql_5="select count(*) from emp where ename=? and empno=?";
//基础变量
String deptNo,dname,loc,ename,password;
Class.forName("com.mysql.jdbc.Driver");
Connection con = DriverManager.getConnection("jdbc:mysql://localhost:3306/bjpowernode", "root", "123");
PreparedStatement ps=null;
System.out.println("******请输入用户名******");
ename = request.next();
System.out.println("******请输入密码******");
password = request.next();
ps = con.prepareStatement(sql_5);
ps.setString(1, ename);
ps.setInt(2, Integer.valueOf(password));
ResultSet rs =ps.executeQuery();
while(rs.next()){
flag = rs.getInt("count(*)");
}
if(rs!=null){
rs.close();
}
if(ps!=null){
ps.close();
}
if(flag!=1){
System.out.println("登录信息不存在，请求重新启动程序重新登录");
return;
}
while(true){
System.out.println("******欢迎使用某某公司部门管理系统******");
System.out.println("******1.添加部门******");
System.out.println("******2.查询部门******");
System.out.println("******3.删除部门******");
System.out.println("******4.更新部门******");
System.out.println("******请输入操作******");
flag = request.nextInt();
if(flag ==1){
System.out.println("******请输入部门编号******");
deptNo =request.next();
System.out.println("******请输入部门名称******");
dname =request.next();
System.out.println("******请输入部门位置******");
loc = request.next();
ps = con.prepareStatement(sql_1);
ps.setInt(1, Integer.valueOf(deptNo));
ps.setString(2, dname);
ps.setString(3, loc);
flag = ps.executeUpdate();
if(ps!=null){
ps.close();
}
if(flag ==1){
System.out.println("部门添加成功！");
}else{
System.out.println("部门添加失败！");
}
}else if(flag ==2){
ps =con.prepareStatement(sql_2);
rs = ps.executeQuery();
while(rs.next()){
deptNo = rs.getString("deptNo");
dname = rs.getString("dname");
loc = rs.getString("loc");
System.out.println("部门编号 "+deptNo+" 部门名称 "+dname+" 部门位置 "+loc);
}
if(rs!=null){
rs.close();
}
if(ps!=null){
ps.close();
}
}else if(flag ==3){
System.out.println("******请输入部门编号******");
deptNo =request.next();
ps = con.prepareStatement(sql_3);
ps.setInt(1, Integer.valueOf(deptNo));
flag = ps.executeUpdate();
if(ps!=null){
ps.close();
}
if(flag ==1){
System.out.println("部门删除成功");
}else{
System.out.println("部门删除失败");
}
}else{
System.out.println("******请输入部门编号******");
deptNo =request.next();
System.out.println("******请输入部门名称******");
dname =request.next();
System.out.println("******请输入部门位置******");
loc = request.next();
ps = con.prepareStatement(sql_4);
ps.setString(1, dname);
ps.setString(2, loc);
ps.setInt(3, Integer.valueOf(deptNo));
flag = ps.executeUpdate();
if(ps!=null){
ps.close();
}
if(flag ==1){
System.out.println("部门信息更新成功");
}else{
System.out.println("部门信息更新失败");
}
}
System.out.println("退出系统请安0，回到上一级菜单按任意键");
flag = request.nextInt();
if(flag==0){
System.out.println("系统正在关闭中。。。。");
//销毁Connection
if(con!=null){
con.close();
}
System.out.println("谢谢使用，系统关闭！");
break;
}
}
}
}```