Java SDK: Migrate from V1 to V2

1
static class DemoTokenProvider implements TokenProvider {
2
    @Override
3
    public String getBearerToken() throws Exception {
4
        ResponseToken res = null;
5
        try {
6
            String filePath = "<YOUR_CREDENTIALS_FILE_HERE>";
7
            res = Token.generateBearerToken(filePath);
8
        } catch (SkyflowException e) {
9
            e.printStackTrace();
10
        }
11
        return res.getAccessToken();
12
    }
13
}

1
// Option 1: API key (recommended)
2
Credentials skyflowCredentials = new Credentials();
3
skyflowCredentials.setApiKey("<YOUR_API_KEY>");
4
5
// Option 2: Environment variable — set SKYFLOW_CREDENTIALS in your environment
6
7
// Option 3: Credentials file
8
skyflowCredentials.setPath("<YOUR_CREDENTIALS_FILE_PATH>");
9
10
// Option 4: Stringified JSON
11
skyflowCredentials.setCredentialsString("<YOUR_CREDENTIALS_STRING>");
12
13
// Option 5: Bearer token
14
skyflowCredentials.setToken("<BEARER_TOKEN>");

1
DemoTokenProvider demoTokenProvider = new DemoTokenProvider();
2
SkyflowConfiguration skyflowConfig = new SkyflowConfiguration(
3
    "<VAULT_ID>",
4
    "<VAULT_URL>",
5
    demoTokenProvider
6
);
7
Skyflow skyflowClient = Skyflow.init(skyflowConfig);

1
Credentials credentials = new Credentials();
2
credentials.setPath("<YOUR_CREDENTIALS_FILE_PATH>");
3
4
VaultConfig config = new VaultConfig();
5
config.setVaultId("<YOUR_VAULT_ID>");
6
config.setClusterId("<YOUR_CLUSTER_ID>"); // ID from your vault URL, e.g., https://{clusterId}.vault.skyflowapis.com
7
config.setEnv(Env.PROD);
8
config.setCredentials(credentials);
9
10
Credentials skyflowCredentials = new Credentials();
11
skyflowCredentials.setPath("<FALLBACK_CREDENTIALS_FILE_PATH>");
12
13
Skyflow skyflowClient = Skyflow.builder()
14
    .setLogLevel(LogLevel.INFO)
15
    .addVaultConfig(config)
16
    .addSkyflowCredentials(skyflowCredentials) // Used as a fallback if no per-vault credentials are set
17
    .build();

1
VaultConfig primary = new VaultConfig();
2
primary.setVaultId("<PRIMARY_VAULT_ID>");
3
primary.setClusterId("<PRIMARY_CLUSTER_ID>");
4
primary.setEnv(Env.PROD);
5
primary.setCredentials(primaryCredentials);
6
7
VaultConfig secondary = new VaultConfig();
8
secondary.setVaultId("<SECONDARY_VAULT_ID>");
9
secondary.setClusterId("<SECONDARY_CLUSTER_ID>");
10
secondary.setEnv(Env.PROD);
11
secondary.setCredentials(secondaryCredentials);
12
13
Skyflow skyflowClient = Skyflow.builder()
14
    .setLogLevel(LogLevel.INFO)
15
    .addVaultConfig(primary)
16
    .addVaultConfig(secondary)
17
    .build();

1
JSONObject recordsJson = new JSONObject();
2
JSONArray recordsArrayJson = new JSONArray();
3
4
JSONObject recordJson = new JSONObject();
5
recordJson.put("table", "cards");
6
7
JSONObject fieldsJson = new JSONObject();
8
fieldsJson.put("cardNumber", "41111111111");
9
fieldsJson.put("cvv", "123");
10
11
recordJson.put("fields", fieldsJson);
12
recordsArrayJson.add(recordJson);
13
recordsJson.put("records", recordsArrayJson);
14
15
JSONObject insertResponse = skyflowClient.insert(recordsJson);

1
ArrayList<HashMap<String, Object>> values = new ArrayList<>();
2
HashMap<String, Object> value = new HashMap<>();
3
value.put("<COLUMN_NAME_1>", "<COLUMN_VALUE_1>");
4
value.put("<COLUMN_NAME_2>", "<COLUMN_VALUE_2>");
5
values.add(value);
6
7
InsertRequest insertRequest = InsertRequest.builder()
8
    .table("<TABLE_NAME>")
9
    .values(values)
10
    .returnTokens(true)
11
    .continueOnError(true)
12
    .build();
13
14
InsertResponse insertResponse = skyflowClient.vault("<VAULT_ID>").insert(insertRequest);

1
GetRequest getRequest = GetRequest.builder()
2
    .table("<TABLE_NAME>")
3
    .ids(Arrays.asList("<SKYFLOW_ID_1>", "<SKYFLOW_ID_2>"))
4
    .returnTokens(true)
5
    .build();
6
GetResponse response = skyflowClient.vault("<VAULT_ID>").get(getRequest);

1
HashMap<String, Object> data = new HashMap<>();
2
data.put("skyflowId", "<SKYFLOW_ID>");
3
data.put("card_number", "<NEW_VALUE>");
4
5
UpdateRequest updateRequest = UpdateRequest.builder()
6
    .table("<TABLE_NAME>")
7
    .data(data)
8
    .returnTokens(true)
9
    .build();
10
UpdateResponse response = skyflowClient.vault("<VAULT_ID>").update(updateRequest);

1
DeleteRequest deleteRequest = DeleteRequest.builder()
2
    .table("<TABLE_NAME>")
3
    .ids(Arrays.asList("<SKYFLOW_ID_1>", "<SKYFLOW_ID_2>"))
4
    .build();
5
DeleteResponse response = skyflowClient.vault("<VAULT_ID>").delete(deleteRequest);

1
DetokenizeRequest detokenizeRequest = DetokenizeRequest.builder()
2
    .tokens(Arrays.asList("<TOKEN_1>", "<TOKEN_2>"))
3
    .build();
4
DetokenizeResponse response = skyflowClient.vault("<VAULT_ID>").detokenize(detokenizeRequest);

1
QueryRequest queryRequest = QueryRequest.builder()
2
    .query("SELECT * FROM <TABLE_NAME> WHERE skyflow_id = \"<SKYFLOW_ID>\"")
3
    .build();
4
QueryResponse response = skyflowClient.vault("<VAULT_ID>").query(queryRequest);

1
InsertOptions insertOptions = new InsertOptions(true);

1
InsertRequest insertRequest = InsertRequest.builder()
2
    .table("<TABLE_NAME>")
3
    .values(values)
4
    .continueOnError(false)
5
    .tokenMode(TokenMode.DISABLE)
6
    .returnTokens(false)
7
    .upsert("<UPSERT_COLUMN>")
8
    .build();

1
HashMap<String, Object> data = new HashMap<>();
2
data.put("skyflowId", "<SKYFLOW_ID>");   // Preferred
3
data.put("card_number", "<NEW_VALUE>");
4
5
UpdateRequest request = UpdateRequest.builder()
6
    .table("<TABLE_NAME>")
7
    .data(data)
8
    .returnTokens(true)
9
    .build();
10
11
skyflowClient.vault("<VAULT_ID>").update(request);