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("<YOUR_CREDENTIALS_FILE_PATH_2>");
12
13
Skyflow skyflowClient = Skyflow.builder()
14
    .setLogLevel(LogLevel.INFO)
15
    .addVaultConfig(config)
16
    .addSkyflowCredentials(skyflowCredentials) // Used if no individual vault credentials are set
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
ArrayList<HashMap<String, Object>> tokens = new ArrayList<>();
8
HashMap<String, Object> token = new HashMap<>();
9
token.put("<COLUMN_NAME_2>", "<TOKEN_VALUE_2>");
10
tokens.add(token);
11
12
InsertRequest insertRequest = InsertRequest.builder()
13
    .table("<TABLE_NAME>")
14
    .values(values)
15
    .tokens(tokens)
16
    .tokenMode(TokenMode.ENABLE)
17
    .returnTokens(true)
18
    .continueOnError(true)
19
    .build();
20
21
InsertResponse insertResponse = skyflowClient.vault("<VAULT_ID>").insert(insertRequest);

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();