Bug Fixed。完成ShellUI、UserDAO、merchantsDAO,测试通过

This commit is contained in:
twinkle255 2023-05-05 20:06:44 +08:00
parent 135e2156dd
commit 3dc0a891fb
12 changed files with 388 additions and 106 deletions

View File

@ -3,9 +3,11 @@
# 2023-03-16
- 初始化项目
# 2023-03-22
- 增加实体类
- 删除.idea文件
# 2023-03-26
- 完善实体类
- 我靠,折腾了一晚上,提交了十几次,终于提交时把.idea这个文件给忽略了
@ -19,20 +21,36 @@
- `update`一下远端项目
- `push`代码
- 我好菜。。。
# 2023-03-27
- 完善了一下实体类,发现商家那一部分漏了一点东西,给它补上了
- 另外就是为什么`.idea`文件我已经取消提交了,为啥本地的`commit`里面还会有有啊……无语了
- 是不是跟`git`八字不合。。。
# 2023-03-29
- 添加`JDBC`驱动,连接数据库
# 2023-05-04
- 创建数据库表,并成功连接
- 调整实体类与数据库对应的结构,修改外键
- 创建数据库表,测试连接成功
- 调整项目结构
- 调整实体类与数据库对应的结构
- 修改外键
- 完成DAO层抽象接口
- 完成MerchantsDAO和UserDAO具体功能
# 2023-05-05
- Debug MerchantsDAO 按ID查询功能
- 完成MerchantsDAO和UserDAO具体功能
# 2023-05-05-NO.1
- Bug fixed: MerchantsDAO 按ID查询功能
- 搭建shellUI的大体框架
- 完成UserDAO具体功能
- 第一次测试
# 2023-05-05-NO.2
- 实现UserDAO和MerchantsDAO所有接口功能
- shellUI完成
- 测试
- UserDAO和MerchantsDAO的增加、查询、删除功能测试通过
- shellUI功能测试通过
- Bug Fixed
- DAO层Merchants、User类查询问题
- 按ID查询报错
- 全部查询只显示最后添加的行
- 输出格式混乱问题

View File

@ -10,4 +10,6 @@ public interface abstractDAO<T> {
int update(T t);//
List<T> search(T t);//
T searchID(Long id);// ByID
}

View File

@ -3,6 +3,5 @@ package dao;
import entities.Merchants;
public interface merchantsAbstractDAO extends abstractDAO<Merchants> {
//根据id查询商家
Merchants searchMerchantByID(Long id);
}

View File

@ -0,0 +1,8 @@
package dao.specification;
import java.util.List;
//@TODO 重构代码 合并userDAO和merchantsDAO中重复方法
public class abstractDAO {
}

View File

@ -16,46 +16,22 @@ public class merchantsDAO implements merchantsAbstractDAO {
private PreparedStatement preparedStatement = null;
private ResultSet resultSet = null;
//通过id寻找商家
@Override
public Merchants searchMerchantByID(Long id) {
Merchants merchants = null;
String selectID_sql = "select * from Merchants where id = ?";
try {
connection = getConnection();
preparedStatement = connection.prepareStatement(selectID_sql);
preparedStatement.setLong(1, id);
resultSet = preparedStatement.executeQuery();
while (resultSet.next()) {
merchants = new Merchants();
merchants.setId(resultSet.getLong("id"));
merchants.setName(resultSet.getString("name"));
merchants.setAddress(resultSet.getString("address"));
merchants.setDescription(resultSet.getString("description"));
merchants.setPhoneNumber(resultSet.getString("phoneNumber"));
}
} catch (SQLException e) {
throw new RuntimeException(e);
} finally {
close(connection, preparedStatement, resultSet);
}
return merchants;
}
//新加商家
@Override
public int insert(@NotNull Merchants merchants) {
int flag = 0;
int flag;
try {
connection = getConnection();
String insert_sql = "insert into Merchants(name,address,description,phoneNumber) values(?,?,?,?)";
String insert_sql = "insert into Merchants(name,address,description,phoneNumber) " +
"values(?,?,?,?)";
preparedStatement = connection.prepareStatement(insert_sql);
preparedStatement.setString(1, merchants.getName());
preparedStatement.setString(2, merchants.getAddress());
preparedStatement.setString(3, merchants.getDescription());
preparedStatement.setString(4, merchants.getPhoneNumber());
flag = preparedStatement.executeUpdate();
} catch (SQLException e) {
throw new RuntimeException(e);
} finally {
@ -73,6 +49,7 @@ public class merchantsDAO implements merchantsAbstractDAO {
String delete_sql = "delete from Merchants where id = ?";
preparedStatement = connection.prepareStatement(delete_sql);
preparedStatement.setLong(1, merchants.getId());
flag = preparedStatement.executeUpdate();
} catch (Exception e) {
e.printStackTrace();
@ -110,13 +87,16 @@ public class merchantsDAO implements merchantsAbstractDAO {
@Override
public List<Merchants> search(Merchants merchants) {
List<Merchants> list = new ArrayList<>();
String selectAll_sql = "select * from Merchants";
try {
connection = getConnection();
String selectAll_sql = "select * from Merchants";
preparedStatement = connection.prepareStatement(selectAll_sql);
resultSet = preparedStatement.executeQuery();
while (resultSet.next()) {
merchants = new Merchants();
merchants.setId(resultSet.getLong("id"));
merchants.setName(resultSet.getString("name"));
merchants.setPhoneNumber(resultSet.getString("phoneNumber"));
@ -133,4 +113,31 @@ public class merchantsDAO implements merchantsAbstractDAO {
return list;
}
//通过id寻找商家
@Override
public Merchants searchID(Long id) {
Merchants merchants = null;
String selectID_sql = "select * from Merchants where id = ?";
try {
connection = getConnection();
preparedStatement = connection.prepareStatement(selectID_sql);
preparedStatement.setLong(1, id);
resultSet = preparedStatement.executeQuery();
while (resultSet.next()) {
merchants = new Merchants();
merchants.setId(resultSet.getLong("id"));
merchants.setName(resultSet.getString("name"));
merchants.setAddress(resultSet.getString("address"));
merchants.setDescription(resultSet.getString("description"));
merchants.setPhoneNumber(resultSet.getString("phoneNumber"));
}
} catch (SQLException e) {
throw new RuntimeException(e);
} finally {
close(connection, preparedStatement, resultSet);
}
return merchants;
}
}

View File

@ -19,13 +19,31 @@ public class userDAO implements userAbstractDAO {
private PreparedStatement preparedStatement = null;
private ResultSet resultSet = null;
//@TODO UserDAO 插入功能
//新建用户
@Override
public int insert(Users users) {
public int insert(@NotNull Users users) {
int flag;
try {
connection = getConnection();
String insert_sql = "insert into Users(name, phoneNumber, address, password) " +
"values (?,?,?,?)";
preparedStatement = connection.prepareStatement(insert_sql);
return 0;
preparedStatement.setString(1, users.getName());
preparedStatement.setString(2, users.getPhoneNumber());
preparedStatement.setString(3, users.getAddress());
preparedStatement.setString(4, users.getPassword());
flag = preparedStatement.executeUpdate();
} catch (SQLException e) {
throw new RuntimeException(e);
} finally {
close(connection, preparedStatement, resultSet);
}
return flag;
}
//删除
@Override
public int delete(@NotNull Users users) {
int flag;
@ -34,8 +52,8 @@ public class userDAO implements userAbstractDAO {
String delete_sql = "delete from Users where id=?";
preparedStatement = connection.prepareStatement(delete_sql);
preparedStatement.setLong(1, users.getId());
flag = preparedStatement.executeUpdate();
flag = preparedStatement.executeUpdate();
} catch (SQLException e) {
throw new RuntimeException(e);
} finally {
@ -45,20 +63,24 @@ public class userDAO implements userAbstractDAO {
return flag;
}
//更新用户个人信息
@Override
public int update(@NotNull Users users) {
int flag = 0;
int flag;
String update_sql = "update Users " +
"set name = ?, phoneNumber = ?, address = ? " +
"where id = ?";
try {
connection = getConnection();
String update_sql = "update Users " +
"set name = ?, phoneNumber = ?, address = ? " +
"where id = ?";
preparedStatement = connection.prepareStatement(update_sql);
preparedStatement.setString(1,users.getName());
preparedStatement.setString(2,users.getPhoneNumber());
preparedStatement.setString(3,users.getAddress());
preparedStatement.setLong(4,users.getId());
preparedStatement.setString(1, users.getName());
preparedStatement.setString(2, users.getPhoneNumber());
preparedStatement.setString(3, users.getAddress());
preparedStatement.setLong(4, users.getId());
flag = preparedStatement.executeUpdate();
} catch (SQLException e) {
throw new RuntimeException(e);
}
@ -69,14 +91,17 @@ public class userDAO implements userAbstractDAO {
@Override
public List<Users> search(Users users) {
List<Users> list = new ArrayList<>();
String selectAll_sql = "select * from Users";
try {
connection = getConnection();
String selectAll_sql = "select * from Users";
preparedStatement = connection.prepareStatement(selectAll_sql);
preparedStatement.executeQuery();
resultSet = preparedStatement.executeQuery();
while (resultSet.next()) {
users = new Users();
users.setName(resultSet.getString("id"));
users.setName(resultSet.getString("name"));
users.setPhoneNumber(resultSet.getString("phoneNumber"));
users.setAddress(resultSet.getString("address"));
@ -92,7 +117,7 @@ public class userDAO implements userAbstractDAO {
//用ID查询用户
@Override
public Users searchUsersByID(Long id) {
public Users searchID(Long id) {
Users user = null;
String selectID_sql = "select * from Users where id = ?";
try {

View File

@ -3,6 +3,5 @@ package dao;
import entities.Users;
public interface userAbstractDAO extends abstractDAO<Users> {
//根据ID查询用户
Users searchUsersByID(Long id);
}

View File

@ -12,12 +12,25 @@ public class Merchants {
private String description;//店铺描述
private String phoneNumber;//商家联系方式
@Override
public String toString() {
return "\n商家编号" + this.id +
"\n店铺名字" + this.name +
"\n店铺地址" + this.address +
"\n店铺描述" + this.description +
"\n联系方式" + this.phoneNumber;
// @Override
// public String toString() {
// return "\n商家编号" + this.id +
// "\n店铺名字" + this.name +
// "\n店铺地址" + this.address +
// "\n店铺描述" + this.description +
// "\n联系方式" + this.phoneNumber;
// }
public Merchants(String name, String address,
String description, String phoneNumber) {
this.name = name;
this.address = address;
this.description = description;
this.phoneNumber = phoneNumber;
}
public Merchants() {
}
}

View File

@ -6,17 +6,28 @@ import lombok.Data;
@Data
public class Users {
private Long id;//主键用户ID
private String password;//用户密码
private String name;//用户姓名
private String phoneNumber;//用户联系方式
private String address;//家庭住址
private String password;//用户密码
// @Override
// public String toString() {
// return "\n用户编号" + this.id +
// "\n用户姓名" + this.name +
// "\n家庭地址" + this.address +
// "\n联系方式" + this.phoneNumber;
// }
public Users() {
@Override
public String toString() {
return "\n用户编号" + this.id +
"\n用户姓名" + this.name +
"\n家庭地址" + this.address +
"\n联系方式" + this.phoneNumber;
}
public Users(String name, String phoneNumber,
String address, String password) {
this.name = name;
this.phoneNumber = phoneNumber;
this.address = address;
this.password = password;
}
}

View File

@ -1,55 +1,157 @@
package example;
import com.microsoft.sqlserver.jdbc.StringUtils;
import dao.*;
import dao.specification.*;
import dao.merchantsAbstractDAO;
import dao.specification.merchantsDAO;
import dao.specification.userDAO;
import dao.userAbstractDAO;
import entities.Merchants;
import entities.Users;
import util.Toolset;
import java.util.Scanner;
public class shellUI {
public static void main(String[] args) {
public static void main(String[] args) throws IllegalAccessException {
run();
}
public static void run() {
Scanner reader = new Scanner(System.in);
public static void run() throws IllegalAccessException {
System.out.println("""
------------------------------------------
----------------后台管理系统----------------
------------------------------------------
""");
Chose();
}
//选项一
private static void Chose() throws IllegalAccessException {
System.out.println("""
请选择你要进行的功能
1.商家管理
2.用户管理
请选择你要进行的功能:
1.商家管理\t2.用户管理\t0.退出
""");
//
int chose1;
while (true) {
if (reader.hasNextInt()) {
chose1 = reader.nextInt();
break;
} else {
System.out.println("你的输入有误,请重新输入!");
switch (Toolset.option()) {
case 0 -> System.exit(0);
//商家
case 1 -> {
System.out.println("""
请选择你想使用的功能:
1.新建商家\t\t2.删除商家\t\t3.更新信息
4.查询所有商家\t5.根据ID查询商家\t0.退出
""");
merchantsDB(Toolset.option());
Chose();
}
//用户
case 2 -> {
System.out.println("""
请选择你想使用的功能:
1.新建用户\t\t2.删除用户\t\t3.更新信息
4.查询所有用户\t5.根据ID查询用户\t0.退出
""");
userDB(Toolset.option());
Chose();
}
}
//@TODO 2023-05-05 shellUI功能选择
int chose2;
switch (chose1) {
case 1:
System.out.println("""
请选择你想使用的功能
1.
2.
3.
4.
5.
""");
break;
case 2:
}
}
//商家数据库操作
private static void merchantsDB(int chose) throws IllegalAccessException {
int flag;
Merchants merchants;
Scanner reader = new Scanner(System.in);
switch (chose) {
case 0 -> System.exit(0);
case 1 -> {//@TODO 输入格式化 不换行
merchantsAbstractDAO DML_insert = new merchantsDAO();
System.out.println("请输入:店铺名字|地址|描述|电话");
merchants = new Merchants(reader.nextLine(), reader.nextLine(), reader.nextLine(), reader.nextLine());
flag = DML_insert.insert(merchants);
System.out.println(flag + "行受影响");
}
case 2 -> {
merchantsAbstractDAO DML_delete = new merchantsDAO();
merchants = new Merchants();
System.out.println("请输入你要删除商家的ID");
merchants.setId(reader.nextLong());
flag = DML_delete.delete(merchants);
System.out.println(flag + "行受影响");
}
case 3 -> {
merchantsAbstractDAO DML_update = new merchantsDAO();
merchants = new Merchants();
flag = DML_update.update(merchants);
System.out.println(flag + "行受影响");
}
case 4 -> {
merchantsAbstractDAO DQL_all = new merchantsDAO();
merchants = new Merchants();
//格式化输出
for (Merchants item : DQL_all.search(merchants)) {
System.out.println(Toolset.table(Merchants.class, item));
}
}
case 5 -> {
merchantsAbstractDAO DQL_ID = new merchantsDAO();
new Merchants();
System.out.println("请输入你要查询的ID:");
merchants = DQL_ID.searchID(reader.nextLong());
//格式化输出
System.out.println(Toolset.table(Merchants.class, merchants));
}
}
}
//用户数据库操作
private static void userDB(int chose) throws IllegalAccessException {
int flag;
Users user;
Scanner reader = new Scanner(System.in);
switch (chose) {
case 0 -> System.exit(0);
case 1 -> {//@TODO 非换行输入
userAbstractDAO DML_insert = new userDAO();
System.out.println("请输入:名字|电话|地址|密码");
user = new Users(reader.nextLine(), reader.nextLine(), reader.nextLine(), reader.nextLine());
flag = DML_insert.insert(user);
System.out.println(flag + "行受影响");
}
case 2 -> {
userAbstractDAO DML_delete = new userDAO();
user = new Users();
flag = DML_delete.delete(user);
System.out.println(flag + "行受影响");
}
case 3 -> {
userAbstractDAO DML_update = new userDAO();
user = new Users();
flag = DML_update.update(user);
System.out.println(flag + "行受影响");
}
case 4 -> {
userAbstractDAO DQL_all = new userDAO();
user = new Users();
//格式化输出
for (Users item : DQL_all.search(user)) {
System.out.println(Toolset.table(Users.class, item));
}
}
case 5 -> {
userAbstractDAO DQL_ID = new userDAO();
new Users();
System.out.println("请输入你要查询的ID:");
user = DQL_ID.searchID(reader.nextLong());
//格式化输出
System.out.println(Toolset.table(Users.class, user));
}
}
}
}

View File

@ -7,10 +7,10 @@ public class SQLDatabaseConnection {
private static final String connectionUrl =
"jdbc:sqlserver://152.136.182.168:1433;"
+ "database=Elm;"
+ "user=guest@152.136.182.168;"
+ "user=guest;"
+ "password=20230504#Guest;"
+ "encrypt=true;"
+ "trustServerCertificate=false;"
+ "trustServerCertificate=true;"
+ "loginTimeout=30;";
public static Connection getConnection() {

View File

@ -0,0 +1,98 @@
package util;
import org.jetbrains.annotations.Contract;
import org.jetbrains.annotations.NotNull;
import java.lang.reflect.Field;
import java.util.Arrays;
import java.util.Map;
import java.util.Scanner;
import java.util.StringJoiner;
import java.util.concurrent.ConcurrentHashMap;
public class Toolset {
public static int option() {
Scanner reader = new Scanner(System.in);
int chose;
//读取选项
while (true) {
if (reader.hasNextInt()) {
chose = reader.nextInt();
break;
} else {
System.out.println("你的输入有误,请重新输入~");
}
}
return chose;
}
//shellUI格式化输出
private static final Map<Class<?>, Field[]> CLASS_2_FIELD_NAME = new ConcurrentHashMap<>();
/**
* 将对象打印成表格
*/
@SafeVarargs
public static <T> String table(Class<T> clazz, T... objs) throws IllegalAccessException {
Field[] fields = safeGetRefCtx(clazz);
if (fields.length == 0) {
return "";
}
// 计算每一列
int[] maxLens = new int[fields.length];
for (int i = 0; i < fields.length; i++) {
final int ti = i;
// 取出当前字段中最长的长度
maxLens[i] = Arrays.stream(objs)
.map(item -> {
try {
return String.valueOf(fields[ti].get(item));
} catch (IllegalAccessException e) {
// pass
}
return "";
})
.mapToInt(String::length)
.max()
.orElse(0);
}
StringJoiner result = new StringJoiner("\n");
for (T obj : objs) {
// 竖线前后加一个空格分割
StringJoiner sj = new StringJoiner(" | ");
for (int i = 0; i < fields.length; i++) {
sj.add(fields[i].getName() + ": " + padRight(String.valueOf(fields[i].get(obj)), maxLens[i]));
}
result.merge(sj);
}
return result.toString();
}
/**
* 右侧补充字符
*/
@Contract(pure = true)
private static @NotNull String padRight(@NotNull String origin, int length) {
StringBuilder originBuilder = new StringBuilder(origin);
while (originBuilder.length() < length) {
originBuilder.append(' ');
}
origin = originBuilder.toString();
return origin;
}
private static Field @NotNull [] safeGetRefCtx(Class<?> clazz) {
Field[] fields = CLASS_2_FIELD_NAME.get(clazz);
if (fields == null) {
fields = clazz.getDeclaredFields();
for (Field field : fields) {
//打开私有访问
field.setAccessible(true);
}
CLASS_2_FIELD_NAME.put(clazz, fields);
}
return fields;
}
}