Add TestSyncUsers().

object/user.go

@@ -120,6 +120,40 @@ func AddUser(user *User) bool {
 	return affected != 0
 }
 
+func AddUsers(users []*User) bool {
+	affected, err := adapter.Engine.Insert(users)
+	if err != nil {
+		panic(err)
+	}
+
+	return affected != 0
+}
+
+func AddUsersSafe(users []*User) bool {
+	batchSize := 1000
+
+	if len(users) == 0 {
+		return false
+	}
+
+	affected := false
+	for i := 0; i < (len(users)-1)/batchSize+1; i++ {
+		start := i * batchSize
+		end := (i + 1) * batchSize
+		if end > len(users) {
+			end = len(users)
+		}
+
+		tmp := users[start:end]
+		fmt.Printf("Add users: [%d - %d].\n", start, end)
+		if AddUsers(tmp) {
+			affected = true
+		}
+	}
+
+	return affected
+}
+
 func DeleteUser(user *User) bool {
 	affected, err := adapter.Engine.ID(core.PK{user.Owner, user.Name}).Delete(&User{})
 	if err != nil {