in src/main/java/com/amazonaws/lambda/oracle/starter/AWSLambdaOracleStarter.java [35:63]
public String handleRequest(Object input, Context context) {
context.getLogger().log("Input: " + input);
String region = Optional.ofNullable(System.getenv("region")).orElse("");
String secretName = Optional.ofNullable(System.getenv("database_secret_name")).orElse("my_oracle_database");
String query = "select * from table_name";
Connection connection = null;
DatabaseCredentials dbCreds = null;
SecretsManagerUtil smUtil = new SecretsManagerUtil();
String secretString = smUtil.getSecretUsingSecretsCache(region, secretName);
if (Optional.ofNullable(secretString).isPresent()) {
dbCreds = smUtil.parseSecretString(secretString);
}
if (Optional.ofNullable(dbCreds.getUserName()).isPresent()
&& Optional.ofNullable(dbCreds.getPassword()).isPresent()
&& Optional.ofNullable(dbCreds.getDbHost()).isPresent()
&& Optional.ofNullable(dbCreds.getDbName()).isPresent()
&& Optional.ofNullable(dbCreds.getDbPort()).isPresent()) {
DatabaseUtil dbUtil = new DatabaseUtil();
connection = dbUtil.getConnection(dbCreds);
}
if (Optional.ofNullable(connection).isPresent()) {
runSampleQuery(connection, query);
}
return "Lambda function to get a list of Databases completed successfully!";
}