Test

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 <T> List<T> select(Class<T> poClass, String... wheres) throws SQLException, ClassNotFoundException {
+    public <T> List<T> select(Class<T> poClass, int pageNumber, int pageSize, String... wheres) throws SQLException, ClassNotFoundException {
         ArrayList<T> 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<Field> 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));
             }

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<User> select = h.select(User.class);
+            List<User> 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();