Check which SRID to use.
- Dominant language
- Java
- Stars
- 274
- Forks
- 140
- Avg merge
- 5d 16h
- Merged PRs (30d)
- 4
Description
Check which SRID to use.
https://github.com/apache/wayang/blob/42e2fa6dce36c7f399d3a96850379ce177809526/wayang-plugins/wayang-spatial/src/main/java/org/apache/wayang/spatial/operators/jdbc/JdbcSpatialFilterOperator.java#L65
```java
/*
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.wayang.spatial.operators.jdbc;
import org.apache.wayang.basic.operators.SpatialFilterOperator;
import org.apache.wayang.core.api.spatial.SpatialGeometry;
import org.apache.wayang.core.api.spatial.SpatialPredicate;
import org.apache.wayang.core.function.FunctionDescriptor;
import org.apache.wayang.core.types.DataSetType;
import org.apache.wayang.spatial.function.JtsSpatialPredicate;
import org.apache.wayang.jdbc.compiler.FunctionCompiler;
import org.apache.wayang.jdbc.operators.JdbcExecutionOperator;
import java.sql.Connection;
/**
* Template for JDBC-based {@link SpatialFilterOperator}.
*/
public abstract class JdbcSpatialFilterOperator extends SpatialFilterOperator implements JdbcExecutionOperator {
/**
* Creates a new instance.
*
* @param relation the type of spatial filter (e.g., "INTERSECTS", "CONTAINS", "WITHIN")
*/
public JdbcSpatialFilterOperator(SpatialPredicate relation,
FunctionDescriptor.SerializableFunction keyExtractor,
DataSetType inputClassDatasetType,
SpatialGeometry geometry) {
super(relation, keyExtractor, inputClassDatasetType, geometry);
}
public JdbcSpatialFilterOperator(SpatialFilterOperator that) {
super(that);
}
@Override
public String createSqlClause(Connection connection, FunctionCompiler compiler) {
if (this.referenceGeometry == null) {
throw new IllegalStateException("Geometry for spatial filter must not be null.");
}
// Column expression (e.g. "geom" or "t.geom")
final String columnExpr = this.keyDescriptor.getSqlImplementation().getField1();
// Geometry literal as ST_GeomFromText('WKT', srid)
final String wkt = this.referenceGeometry.toWKT();
// TODO: Check which SRID to use.
final int srid = 4326;
final String geomLiteral;
if (srid > 0) {
geomLiteral = String.format("ST_GeomFromText('%s', %d)", wkt, srid);
} else {
geomLiteral = String.format("ST_GeomFromText('%s')", wkt);
}
JtsSpatialPredicate relation = JtsSpatialPredicate.of(this.predicateType);
return relation.toSql(columnExpr, geomLiteral);
}
}
```
cedb5ec698a91f195a8cb09cf4f002e2b1be2254
Contributor guide
Assessment
This issue has not been assessed yet.