Merge pull request #254 from supertokens/feat/bulk_migration_returns_userids

feat: bulk migration returns userids

Author: porcellus

CHANGELOG.md

@@ -7,6 +7,10 @@ to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
 ## [Unreleased]
 
+## [8.1.1]
+
+- Adds more null and empty checks for bulk migration
+
 ## [8.1.0]
 
 - Adds support for webauthn (passkeys)

build.gradle

@@ -2,7 +2,7 @@ plugins {
     id 'java-library'
 }
 
-version = "8.1.0"
+version = "8.1.1"
 
 repositories {
     mavenCentral()

src/main/java/io/supertokens/storage/postgresql/queries/BulkImportQueries.java

@@ -76,6 +76,9 @@ public static String getQueryToCreatePaginationIndex2(Start start) {
 
     public static void insertBulkImportUsers_Transaction(Start start, Connection connection, AppIdentifier appIdentifier, List<BulkImportUser> users)
             throws SQLException, StorageQueryException {
+        if(users == null || users.isEmpty()){
+            return;
+        }
         String queryBuilder = "INSERT INTO " + Config.getConfig(start).getBulkImportUsersTable() +
                 " (id, app_id, raw_data, created_at, updated_at) VALUES "
                 + " (?, ?, ?, ?, ?)";
@@ -118,6 +121,9 @@ public static void updateBulkImportUserStatus_Transaction(Start start, Connectio
     public static void updateMultipleBulkImportUsersStatusToError_Transaction(Start start, Connection con, AppIdentifier appIdentifier,
                                                                               @Nonnull Map<String,String> bulkImportUserIdToErrorMessage)
             throws SQLException, StorageQueryException {
+        if(bulkImportUserIdToErrorMessage == null || bulkImportUserIdToErrorMessage.isEmpty()){
+            return;
+        }
         BULK_IMPORT_USER_STATUS errorStatus = BULK_IMPORT_USER_STATUS.FAILED;
         String query = "UPDATE " + Config.getConfig(start).getBulkImportUsersTable()
                 + " SET status = ?, error_msg = ?, updated_at = ? WHERE app_id = ? and id = ?";