software.amazon.jdbc.plugin.encryption.sql

Class SqlAnalysisService

java.lang.Object

software.amazon.jdbc.plugin.encryption.sql.SqlAnalysisService

public class SqlAnalysisService
extends java.lang.Object

Service that analyzes SQL statements to identify columns that need encryption/decryption. Uses jOOQ parser via SQLAnalyzer class.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SqlAnalysisService.SqlAnalysisResult Result of SQL analysis containing affected tables and encrypted columns.

Constructor Summary

Constructors

Constructor and Description
SqlAnalysisService(PluginService pluginService, MetadataManager metadataManager)

Method Summary

Modifier and Type	Method and Description
static SqlAnalysisService.SqlAnalysisResult	analyzeSql(java.lang.String sql) Analyzes a SQL statement to determine which columns need encryption/decryption.
static SqlAnalysisService.SqlAnalysisResult	analyzeSql(java.lang.String sql, java.lang.String jdbcUrl) Analyzes a SQL statement.
java.util.Map<java.lang.Integer,java.lang.String>	getColumnParameterMapping(java.lang.String sql) Gets column-to-parameter mapping for prepared statement parameters.
java.util.Map<java.lang.Integer,java.lang.String>	getColumnParameterMapping(java.lang.String sql, java.lang.String jdbcUrl) Gets column-to-parameter mapping.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SqlAnalysisService

public SqlAnalysisService(PluginService pluginService,
                          MetadataManager metadataManager)

Method Detail

analyzeSql

public static SqlAnalysisService.SqlAnalysisResult analyzeSql(java.lang.String sql)

Analyzes a SQL statement to determine which columns need encryption/decryption.

Parameters:

sql - The SQL statement to analyze

Returns:

Analysis result containing affected columns and their encryption configs

analyzeSql

public static SqlAnalysisService.SqlAnalysisResult analyzeSql(java.lang.String sql,
                                                              java.lang.String jdbcUrl)

Analyzes a SQL statement.

Parameters:

sql - The SQL statement to analyze

jdbcUrl - JDBC URL (unused, kept for compatibility)

Returns:

Analysis result containing affected columns and their encryption configs

getColumnParameterMapping

public java.util.Map<java.lang.Integer,java.lang.String> getColumnParameterMapping(java.lang.String sql)

Gets column-to-parameter mapping for prepared statement parameters.

Parameters:

sql - the SQL statement to analyze

Returns:

a map of parameter index to column name

getColumnParameterMapping

public java.util.Map<java.lang.Integer,java.lang.String> getColumnParameterMapping(java.lang.String sql,
                                                                                   java.lang.String jdbcUrl)

Gets column-to-parameter mapping.

Parameters:

sql - the SQL statement to analyze

jdbcUrl - the JDBC URL for context, or null

Returns:

a map of parameter index to column name