diff --git a/src/main/java/SqliteClient.java b/src/main/java/SqliteClient.java index ffd4d6f..d70f953 100644 --- a/src/main/java/SqliteClient.java +++ b/src/main/java/SqliteClient.java @@ -129,11 +129,11 @@ public class SqliteClient { sql.append(aClass.getSimpleName().toUpperCase()); if (wheres.length > 0) { - sql.append(" WHERE"); + sql.append(" WHERE "); for (int i = 0; i < wheres.length; i++) { String where = wheres[i]; sql.append(where); - sql.append(i != wheres.length ? " AND " : ""); + sql.append(i != wheres.length - 1 ? " AND " : ""); } } return executeUpdate(sql.toString()); @@ -182,11 +182,11 @@ public class SqliteClient { } if (wheres.length > 0) { - sql.append(" WHERE"); + sql.append(" WHERE "); for (int i = 0; i < wheres.length; i++) { String where = wheres[i]; sql.append(where); - sql.append(i != wheres.length ? " AND " : ""); + sql.append(i != wheres.length - 1 ? " AND " : ""); } } @@ -201,7 +201,7 @@ public class SqliteClient { return 0; } - public List select(Class poClass, String... wheres) throws SQLException, ClassNotFoundException { + public List select(Class poClass, int pageNumber, int pageSize, String... wheres) throws SQLException, ClassNotFoundException { ArrayList list = new ArrayList<>(); try { Class aClass = classMap.get(poClass.getName()); @@ -211,7 +211,7 @@ public class SqliteClient { StringBuffer sql = new StringBuffer(); sql.append("SELECT "); - //获取字段列表 + //查询字段 List fs = new ArrayList<>(); for (Field f : poClass.getDeclaredFields()) { if (f.isAnnotationPresent(Varchar.class)) { @@ -229,15 +229,19 @@ public class SqliteClient { sql.append(" FROM "); sql.append(aClass.getSimpleName().toUpperCase()); + //条件参数 if (wheres.length > 0) { - sql.append(" WHERE"); + sql.append(" WHERE "); for (int i = 0; i < wheres.length; i++) { String where = wheres[i]; sql.append(where); - sql.append(i != wheres.length ? " AND " : ""); + sql.append(i != wheres.length - 1 ? " AND " : ""); } } + //分页参数 + sql.append(" LIMIT " + (pageNumber - 1) + "," + pageSize); + System.out.println("SQL ==> " + sql.toString()); list.addAll(executeQuery(sql.toString(), poClass)); } diff --git a/src/test/java/SqliteTest.java b/src/test/java/SqliteTest.java index d810959..fc3b698 100644 --- a/src/test/java/SqliteTest.java +++ b/src/test/java/SqliteTest.java @@ -15,23 +15,23 @@ public class SqliteTest { System.out.println("测试 insert"); User user = new User(); - user.setName("wangbingwangbingwangbingwangbingwangbingwangbingwangbingwangbingwangbingwangbingwangbingwangbingwangbingwangbingwangbingwangbingwangbingwangbingwangbingwangbingwangbingwangbingwangbingwangbing"); + user.setName("wangbing"); user.setPassword("test"); h.insert(User.class, user); System.out.println("测试 select"); - List select = h.select(User.class); + List select = h.select(User.class,1,10); System.out.println(select.size()); -// System.out.println("测试 update"); -// user.setName("=="); -// user.setPassword("=="); -// int update = h.update(User.class, user); -// System.out.println(select.size()); + System.out.println("测试 update"); + user.setName("=="); + user.setPassword("=="); + int update = h.update(User.class, user); + System.out.println(select.size()); -// System.out.println("测试 delete"); -// int delete = h.delete(User.class); -// System.out.println(delete); + System.out.println("测试 delete"); + int delete = h.delete(User.class,"NAME = '=='"); + System.out.println(delete); } catch (ClassNotFoundException e) { e.printStackTrace();