in cloud-spanner-r2dbc/src/main/java/com/google/cloud/spanner/r2dbc/v2/SpannerClientLibraryConnection.java [113:124]
public Statement createStatement(String query) {
if (query == null) {
throw new IllegalArgumentException("Invalid null query.");
}
StatementType type = StatementParser.getStatementType(query);
if (type == StatementType.DDL) {
return new SpannerClientLibraryDdlStatement(query, this.clientLibraryAdapter);
} else if (type == StatementType.DML) {
return new SpannerClientLibraryDmlStatement(this.clientLibraryAdapter, query);
}
return new SpannerClientLibraryStatement(this.clientLibraryAdapter, query);
}