Start Lambda connection infrastructure

This commit is contained in:
NMerz 2020-09-20 23:33:36 -04:00
parent f576307e0a
commit 74eeb2a09d
6 changed files with 65 additions and 0 deletions

1
.gitignore vendored
View File

@ -84,3 +84,4 @@ lint/generated/
lint/outputs/ lint/outputs/
lint/tmp/ lint/tmp/
# lint/reports/ # lint/reports/
Lambdas/Lists/src/main/resources/dbProperties.json

View File

@ -24,5 +24,19 @@
<artifactId>aws-lambda-java-log4j2</artifactId> <artifactId>aws-lambda-java-log4j2</artifactId>
<version>1.2.0</version> <version>1.2.0</version>
</dependency> </dependency>
<dependency>
<groupId>org.json</groupId>
<artifactId>json</artifactId>
<version>20200518</version>
</dependency>
<dependency>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-compiler-plugin</artifactId>
<version>3.8.1</version>
</dependency>
</dependencies> </dependencies>
<properties>
<maven.compiler.source>1.11</maven.compiler.source>
<maven.compiler.target>1.11</maven.compiler.target>
</properties>
</project> </project>

View File

@ -0,0 +1,32 @@
import org.json.JSONObject;
import java.io.IOException;
import java.nio.file.Files;
import java.nio.file.Path;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.util.Properties;
public class DBConnector {
Connection connection;
DBConnector() throws IOException, SQLException {
this(loadProperties("dbProperties.json"));
}
DBConnector(Properties dbProperties) throws SQLException {
System.out.println(dbProperties);
connection = DriverManager.getConnection(dbProperties.get("url").toString(), dbProperties);
}
public static Properties loadProperties(String path) throws IOException {
Properties toReturn = new Properties();
String propertiesJSONString = Files.readString(Path.of(path));
JSONObject propertiesJSON = new JSONObject(propertiesJSONString);
propertiesJSON.keys().forEachRemaining(key -> toReturn.setProperty(key, propertiesJSON.get(key).toString()));
return toReturn;
}
}

View File

@ -1,3 +1,5 @@
import java.io.IOException;
import java.sql.SQLException;
import java.util.Map; import java.util.Map;
import com.amazonaws.services.lambda.runtime.Context; import com.amazonaws.services.lambda.runtime.Context;
@ -17,6 +19,13 @@ public class ListAdd implements RequestHandler<Map<String,Object>, String>{
} }
System.out.println(inputMap.get("context")); System.out.println(inputMap.get("context"));
System.out.println(contextMap.get("sub")); System.out.println(contextMap.get("sub"));
try {
System.out.println(new DBConnector());
} catch (IOException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
}
return null; return null;
} }
} }

View File

@ -0,0 +1,4 @@
public class ListAdder {
}

View File

@ -0,0 +1,5 @@
{
"url": "http://aws.com/something",
"user": "aUser",
"password": "aPassword"
}