Application: gvSIG desktop

package org.gvsig.fmap.dal.feature.spi;

import java.text.MessageFormat;

import java.util.ArrayList;

import java.util.Collection;

import java.util.Collections;

import java.util.HashMap;

import java.util.HashSet;

import java.util.List;

import java.util.Map;

import java.util.Objects;

import java.util.Set;

import org.apache.commons.lang3.ObjectUtils;

import org.apache.commons.lang3.StringUtils;

import org.apache.commons.lang3.tuple.ImmutablePair;

import org.apache.commons.lang3.tuple.Pair;

import org.cresques.cts.IProjection;

import org.gvsig.expressionevaluator.ExpressionBuilder;

import static org.gvsig.expressionevaluator.ExpressionBuilder.Config.geometry_type_support;

import static org.gvsig.expressionevaluator.ExpressionBuilder.Config.has_spatial_functions;

import org.gvsig.expressionevaluator.ExpressionEvaluatorLocator;

import org.gvsig.fmap.dal.DataStoreParameters;

import org.gvsig.fmap.dal.DataTypes;

import org.gvsig.fmap.dal.SQLBuilder;

import org.gvsig.fmap.dal.SQLBuilder.AlterTableBuilder;

import org.gvsig.fmap.dal.SQLBuilder.CreateTableBuilder;

import org.gvsig.fmap.dal.SQLBuilder.DeleteBuilder;

import org.gvsig.fmap.dal.SQLBuilder.DropTableBuilder;

import org.gvsig.fmap.dal.SQLBuilder.FromBuilder;

import org.gvsig.fmap.dal.SQLBuilder.GrantBuilder;

import org.gvsig.fmap.dal.SQLBuilder.InsertBuilder;

import org.gvsig.fmap.dal.SQLBuilder.InsertColumnBuilder;

import org.gvsig.fmap.dal.SQLBuilder.OrderByBuilder;

import org.gvsig.fmap.dal.SQLBuilder.Privilege;

import org.gvsig.fmap.dal.SQLBuilder.SQLConfig;

import org.gvsig.fmap.dal.SQLBuilder.SelectBuilder;

import org.gvsig.fmap.dal.SQLBuilder.SelectColumnBuilder;

import org.gvsig.fmap.dal.SQLBuilder.TableNameBuilder;

import org.gvsig.fmap.dal.SQLBuilder.UpdateBuilder;

import org.gvsig.fmap.dal.SQLBuilder.UpdateColumnBuilder;

import org.gvsig.fmap.dal.SQLBuilder.UpdateTableStatisticsBuilder;

import org.gvsig.fmap.dal.feature.FeatureAttributeDescriptor;

import org.gvsig.fmap.dal.feature.FeatureStore;

import org.gvsig.fmap.geom.Geometry;

import org.gvsig.fmap.geom.primitive.Envelope;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

public class SQLBuilderBase implements SQLBuilder {

    protected static final Logger logger = LoggerFactory.getLogger(SQLBuilderBase.class);

    protected SelectBuilder select;

    protected UpdateBuilder update;

    protected InsertBuilder insert;

    protected DeleteBuilder delete;

    protected AlterTableBuilder alter_table;

    protected CreateTableBuilder create_table;

    protected GrantBuilder grant;

    protected DropTableBuilder drop_table;

    protected UpdateTableStatisticsBuilder update_table_statistics;

    protected CreateIndexBuilder create_index;

    protected List<Parameter> parameters;

    public class ConfigBase implements Config {

        protected Map<String, Object> values;

        public ConfigBase() {

            this.values = new HashMap<>();

        }

        @Override

        public boolean has_functionality(String functionality) {

            Object x = this.values.get(functionality);

            if (x == null) {

                return false;

            }

            if (x instanceof CharSequence && StringUtils.isEmpty((CharSequence) x)) {

                return false;

            }

            return true;

        }

        @Override

        public void remove_functionality(String functionality) {

            this.values.remove(functionality);

        }

        @Override

        public boolean has_spatial_functions() {

            return this.getBoolean(has_spatial_functions);

        }

        @Override

        public GeometrySupportType getGeometryTypeSupport() {

            return (GeometrySupportType) this.get(geometry_type_support);

        }

        @Override

        public boolean getBoolean(String name) {

            return (boolean) this.values.get(name);

        }

        @Override

        public String getString(String name) {

            return (String) this.values.get(name);

        }

        @Override

        public Object get(String name) {

            return this.values.get(name);

        }

        @Override

        public void set(String name, Object value) {

            this.values.put(name, value);

        }

    }

    public abstract class AbstractValue implements Value {

        @Override

        public void accept(Visitor visitor, VisitorFilter filter) {

            if (filter == null || filter.accept(this)) {

                visitor.visit(this);

            }

        }

    }

    public class ClassVisitorFilter implements VisitorFilter {

        private final Class classFilter;

        public ClassVisitorFilter(Class classFilter) {

            this.classFilter = classFilter;

        }

        @Override

        public boolean accept(Visitable visitable) {

            return classFilter.isInstance(visitable);

        }

    }

    public class GroupBase extends AbstractValue implements Group {

        protected Value value;

        public GroupBase(Value value) {

            this.value = value;

        }

        @Override

        public Value getValue() {

            return value;

        }

        @Override

        public void accept(Visitor visitor, VisitorFilter filter) {

            super.accept(visitor, filter);

            this.value.accept(visitor, filter);

        }

        @Override

        public String toString() {

            return MessageFormat.format(config.getString(Config.group), this.value.toString());

        }

    }

    protected class ColumnDescriptorBase implements ColumnDescriptor {

        private String name;

        private int type;

        private int type_p;

        private int type_s;

        private boolean isPk;

        private boolean _allowNulls;

        private boolean _isAutomatic;

        private Object defaultValue;

        private int geom_type;

        private int geom_subtype;

        private Object geom_srsdbcode;

        private boolean _isIndexed;

        private DataStoreParameters parameters = null;

        public ColumnDescriptorBase(String name, int type, Object defaultValue) {

            this.name = name;

            this.type = type;

            this.type_p = -1;

            this.type_s = -1;

            this.isPk = false;

            this._allowNulls = true;

            this._isAutomatic = false;

            this.defaultValue = defaultValue;

            this.geom_type = Geometry.TYPES.GEOMETRY;

            this.geom_subtype = Geometry.SUBTYPES.GEOM2D;

            this.geom_srsdbcode = null;

            this._isIndexed = false;

        }

        public ColumnDescriptorBase(String name, int type, int type_p, int type_s, boolean isPk, boolean isIndexed, boolean allowNulls, boolean isAutomatic, Object defaultValue) {

            this.name = name;

            this.type = type;

            this.type_p = type_p;

            this.type_s = type_s;

            this.isPk = isPk;

            this._allowNulls = allowNulls;

            this._isAutomatic = isAutomatic;

            this.defaultValue = defaultValue;

            this.geom_type = Geometry.TYPES.GEOMETRY;

            this.geom_subtype = Geometry.SUBTYPES.GEOM2D;

            this.geom_srsdbcode = null;

            this._isIndexed = isIndexed;

        }

        public ColumnDescriptorBase(String name, int geom_type, int geom_subtype, IProjection proj, boolean isIndexed, boolean allowNulls) {

            this.name = name;

            this.type = DataTypes.GEOMETRY;

            this.type_p = 0;

            this.type_s = 0;

            this.isPk = false;

            this._allowNulls = allowNulls;

            this._isAutomatic = false;

            this.defaultValue = null;

            this.geom_type = geom_type;

            this.geom_subtype = geom_subtype;

            this.geom_srsdbcode = getSRSId(proj);

            this._isIndexed = isIndexed;

        }

        public ColumnDescriptorBase(String name, int geom_type, int geom_subtype, Object srsdbcode, boolean isIndexed, boolean allowNulls) {

            this.name = name;

            this.type = DataTypes.GEOMETRY;

            this.type_p = 0;

            this.type_s = 0;

            this.isPk = false;

            this._allowNulls = allowNulls;

            this._isAutomatic = false;

            this.defaultValue = null;

            this.geom_type = geom_type;

            this.geom_subtype = geom_subtype;

            this.geom_srsdbcode = srsdbcode;

            this._isIndexed = isIndexed;

        }

        @Override

        public String getName() {

            return this.name;

        }

        @Override

        public void setName(String name) {

            this.name = name;

        }

        @Override

        public int getType() {

            return this.type;

        }

        @Override

        public void setType(int type) {

            this.type = type;

        }

        @Override

        public int getPrecision() {

            return type_p;

        }

        @Override

        public void setPrecision(int precision) {

            this.type_p = precision;

        }

        @Override

        public int getSize() {

            return type_s;

        }

        @Override

        public void setSize(int size) {

            this.type_s = size;

        }

        @Override

        public boolean isPrimaryKey() {

            return isPk;

        }

        @Override

        public void setIsPrimaryKey(boolean isPk) {

            this.isPk = isPk;

        }

        @Override

        public boolean allowNulls() {

            return _allowNulls;

        }

        @Override

        public void setAllowNulls(boolean allowNulls) {

            this._allowNulls = allowNulls;

        }

        @Override

        public boolean isAutomatic() {

            return _isAutomatic;

        }

        @Override

        public boolean isIndexed() {

            return _isIndexed;

        }

        @Override

        public void setIsAutomatic(boolean isAutomatic) {

            this._isAutomatic = isAutomatic;

        }

        @Override

        public Object getDefaultValue() {

            return defaultValue;

        }

        @Override

        public void setDefaultValue(Object defaultValue) {

            this.defaultValue = defaultValue;

        }

        @Override

        public int getGeometryType() {

            return geom_type;

        }

        @Override

        public void setGeometryType(int geom_type) {

            this.geom_type = geom_type;

        }

        @Override

        public int getGeometrySubtype() {

            return geom_subtype;

        }

        @Override

        public void setGeometrySubtype(int geom_subtype) {

            this.geom_subtype = geom_subtype;

        }

        @Override

        public Object getGeometrySRSId() {

            return geom_srsdbcode;

        }

        @Override

        public void setGeometrySRSId(Object geom_srsid) {

            this.geom_srsdbcode = geom_srsid;

        }        

        @Override

        public boolean isGeometry() {

            return this.type == DataTypes.GEOMETRY;

        }

        private void setStoreParameters(DataStoreParameters parameters) {

            this.parameters = parameters;

        }

        @Override

        public DataStoreParameters getStoreParameters() {

            return this.parameters;

        }

    }

    public class VariableBase extends AbstractValue implements Column {

        protected ColumnDescriptor descriptor;

        protected String name;

        public VariableBase(ColumnDescriptor descriptor) {

            this.name = descriptor.getName();

            this.descriptor = descriptor;

        }

        public VariableBase(String name) {

            this.name = name;

            this.descriptor = null;

        }

        @Override

        public ColumnDescriptor getDescriptor() {

            return descriptor;

        }

        @Override

        public String getName() {

            return this.name;

        }

        @Override

        public String toString() {

            return identifier(this.name);

        }

        @Override

        public int compareTo(ExpressionBuilder.Variable o) {

            return this.name.compareTo(o.getName());

        }

        @Override

        public boolean equals(Object obj) {

            if (!(obj instanceof ExpressionBuilder.Variable)) {

                return false;

            }

            return this.name.equals(((ExpressionBuilder.Variable) obj).getName());

        }

        @Override

        public int hashCode() {

            int hash = 7;

            hash = 37 * hash + Objects.hashCode(this.name);

            return hash;

        }

    }

    public class ParameterBase extends AbstractValue implements Parameter {

        protected String name;

        protected Object value;

        protected ParameterType type;

        protected Value srs;

        public ParameterBase() {

            this.type = ParameterType.Constant;

            this.name = null;

            this.value = null;

        }

        @Override

        public void accept(Visitor visitor, VisitorFilter filter) {

            super.accept(visitor, filter);

            if (this.srs != null) {

                this.srs.accept(visitor, filter);

            }

        }

        @Override

        public Parameter as_geometry_variable() {

            this.type = ParameterType.Geometry;

            if (this.value == null && this.name != null) {

                this.value = this.name;

            }

            return this;

        }

        @Override

        public Parameter as_constant() {

            this.type = ParameterType.Constant;

            if (this.value == null && this.name != null) {

                this.value = this.name;

            }

            return this;

        }

        @Override

        public Parameter as_variable() {

            this.type = ParameterType.Variable;

            if (this.value != null && this.name == null) {

                this.name = (String) this.value;

            }

            return this;

        }

        @Override

        public Parameter srs(Value srs) {

            this.srs = srs;

            if( this.type == ParameterType.Variable ) {

                this.type = ParameterType.Geometry;

            }

            return this;

        }

        @Override

        public Parameter srs(IProjection srs) {

            this.srs = constant(getSRSId(srs));

            if( this.type == ParameterType.Variable ) {

                this.type = ParameterType.Geometry;

            }

            return this;

        }

        @Override

        public String getName() {

            switch (this.type) {

                case Variable:

                case Geometry:

                    return this.name;

                case Constant:

                    if (this.value == null) {

                        return null;

                    }

                    return this.value.toString();

                default:

                    if (this.name != null) {

                        return this.name;

                    }

                    if (this.value != null) {

                        return this.value.toString();

                    }

                    return null;

            }

        }

        @Override

        public boolean is_constant() {

            return this.type == ParameterType.Constant;

        }

        @Override

        public boolean is_geometry_variable() {

            return this.type == ParameterType.Geometry;

        }

        @Override

        public boolean is_variable() {

            return this.type == ParameterType.Variable;

        }

        @Override

        public Parameter value(Object value) {

            this.value = value;

            return this;

        }

        @Override

        public Parameter name(String name) {

            this.type = ParameterType.Variable;

            this.name = name;

            return this;

        }

        @Override

        public Object getValue() {

            try {

                switch (this.type) {

                    case Constant:

                        if (this.value instanceof Geometry) {

                            switch (config.getGeometryTypeSupport()) {

                                case EWKB:

                                    return bytearray(((Geometry) this.value).convertToEWKB());

                                case NATIVE:

                                case WKB:

                                    return bytearray(((Geometry) this.value).convertToWKB());

                                case WKT:

                                default:

                                    return ((Geometry) this.value).convertToWKT();

                            }

                        } else if (this.value instanceof IProjection) {

                            return getSRSId((IProjection) this.value);

                        }

                        return this.value;

                    case Variable:

                    case Geometry:

                    default:

                        return this.value;

                }

            } catch (Exception ex) {

                throw new RuntimeException("Can't get value from parameter.", ex);

            }

        }

        @Override

        public ParameterType getType() {

            return this.type;

        }

        @Override

        public Value getSRS() {

            return this.srs;

        }

        @Override

        public String toString() {

            switch (this.type) {

                case Constant:

                case Variable:

                default:

                    return "?";

                case Geometry:

                    switch (config.getGeometryTypeSupport()) {

                        case EWKB:

                            return MessageFormat.format(

                                    config.getString(Config.ST_GeomFromEWKB),

                                    "?",

                                    String.valueOf(this.srs.toString())

                            );

                        case WKB:

                            return MessageFormat.format(

                                    config.getString(Config.ST_GeomFromWKB),

                                    "?",

                                    String.valueOf(this.srs.toString())

                            );

                        case WKT:

                        default:

                            return MessageFormat.format(

                                    config.getString(Config.ST_GeomFromText),

                                    "?",

                                    String.valueOf(this.srs.toString())

                            );

                    }

            }

        }

    }

    public class ConstantBase extends AbstractValue implements Constant {

        protected Object value;

        public ConstantBase(Object value) {

            this.value = value;

        }

        @Override

        public Object getValue() {

            return this.value;

        }

        @Override

        public String toString() {

            if (this.value instanceof String) {

                return string((String) this.value);

            }

            if (this.value instanceof Boolean) {

                if (((Boolean) this.value)) {

                    return config.getString(Config.constant_true);

                } else {

                    return config.getString(Config.constant_false);

                }

            }

            return ObjectUtils.toString(this.value, "");

        }

    }

    public class CustomBase extends AbstractValue implements Custom {

        protected Object value;

        // Esto es para permitir declarar parametros y columnas en una seccion

        // custom.

        protected List<Value> values;

        public CustomBase(Object value) {

            this.value = value;

        }

        @Override

        public void accept(Visitor visitor, VisitorFilter filter) {

            super.accept(visitor, filter);

            if (this.values != null) {

                for (Value value : values) {

                    value.accept(visitor, filter);

                }

            }

        }

        @Override

        public Object getValue() {

            return this.value;

        }

        @Override

        public Custom add(Variable variable) {

            if (this.values == null) {

                this.values = new ArrayList<>();

            }

            this.values.add(variable);

            return this;

        }

        @Override

        public Custom add(Parameter parameter) {

            if (this.values == null) {

                this.values = new ArrayList<>();

            }

            this.values.add(parameter);

            return this;

        }

        @Override

        public String toString() {

            return ObjectUtils.toString(this.value, "");

        }

    }

    public class GeometryValueBase extends AbstractValue implements GeometryValue {

        protected Geometry geometry;

        protected IProjection projection;

        public GeometryValueBase(Geometry geometry, IProjection projection) {

            this.geometry = geometry;

            this.projection = projection;

        }

        @Override

        public Geometry getGeometry() {

            return this.geometry;

        }

        @Override

        public IProjection getSRS() {

            return this.projection;

        }

        @Override

        public String toString() {

            try {

                switch (config.getGeometryTypeSupport()) {

                    case EWKB:

                        return MessageFormat.format(

                                config.getString(Config.ST_GeomFromEWKB),

                                bytearray(this.geometry.convertToEWKB()),

                                String.valueOf(getSRSId(this.projection))

                        );

                    case WKB:

                        return MessageFormat.format(

                                config.getString(Config.ST_GeomFromWKB),

                                bytearray(this.geometry.convertToWKB()),

                                String.valueOf(getSRSId(this.projection))

                        );

                    case WKT:

                    default:

                        return MessageFormat.format(

                                config.getString(Config.ST_GeomFromText),

                                string(this.geometry.convertToWKT()),

                                String.valueOf(getSRSId(this.projection))

                        );

                }

            } catch (Exception ex) {

                throw new RuntimeException("Can't convert geometry to string.", ex);

            }

        }

    }

    public class FunctionBase extends AbstractValue implements Function {

        protected String name;

        protected String format;

        protected List<Value> parameters;

        public FunctionBase(String name, String format) {

            this.name = name;

            this.format = format;

        }

        public FunctionBase(String name) {

            this(name,null);

        }

        @Override

        public List<Value> parameters() {

            if (this.parameters == null) {

                this.parameters = new ArrayList<>();

            }

            return this.parameters;

        }

        @Override

        public Function parameter(Value parameter) {

            this.parameters().add(parameter);

            return this;

        }

        @Override

        public String getName() {

            return this.name;

        }

        @Override

        public void accept(Visitor visitor, VisitorFilter filter) {

            super.accept(visitor, filter);

            for (Value value : this.parameters) {

                value.accept(visitor, filter);

            }

        }

        @Override

        public String toString() {

            if( this.format==null ) {

                StringBuilder builder = new StringBuilder();

                builder.append(name);

                builder.append("(");

                if (this.parameters != null && !this.parameters.isEmpty()) {

                    boolean first = true;

                    for (Value value : this.parameters) {

                        if( first ) {

                            first=false;

                            builder.append(value.toString());

                        } else {

                            builder.append(", ");

                            builder.append(value.toString());

                        }

                    }

                }

                builder.append(")");

                return builder.toString();

            }

            if (this.parameters != null && !this.parameters.isEmpty()) {

                List<String> values = new ArrayList<>();

                for (Value value : this.parameters) {

                    values.add(value.toString());

                }

                return MessageFormat.format(format, values.toArray());

            } else {

                return this.format;

            }

        }

    }

    public class BinaryOperatorBase extends AbstractValue implements BinaryOperator {

        protected String name;

        protected String format;

        protected Value left;

        protected Value right;

        public BinaryOperatorBase(String name, String format) {

            this.name = name;

            this.format = format;

        }

        @Override

        public String getName() {

            return this.name;

        }

        @Override

        public void accept(Visitor visitor, VisitorFilter filter) {

            super.accept(visitor, filter);

            this.left.accept(visitor, filter);

            this.right.accept(visitor, filter);

        }

        @Override

        public BinaryOperator setLeft(Value operand) {

            this.left = operand;

            return this;

        }

        @Override

        public BinaryOperator setRight(Value operand) {

            this.right = operand;

            return this;

        }

        @Override

        public Value getLeft() {

            return this.left;

        }

        @Override

        public Value getRight() {

            return this.right;

        }

        @Override

        public String toString() {

            return MessageFormat.format(

                    format,

                    this.left.toString(),

                    this.right.toString()

            );

        }

    }

    public class TableNameBuilderBase implements TableNameBuilder {

        public String tableName;

        public String schemaName;

        private String databaseName;

        public TableNameBuilderBase() {

        }

        @Override

        public void accept(Visitor visitor, VisitorFilter filter) {

            if( filter.accept(this) ) {

                visitor.visit(this);

            }

        }

        @Override

        public TableNameBuilder database(String name) {

            this.databaseName = name;

            return this;

        }

        @Override

        public TableNameBuilder schema(String name) {

            if( supportSchemas() ) {

                this.schemaName = name;

            }

            return this;

        }

        @Override

        public TableNameBuilder name(String name) {

            this.tableName = name;

            return this;

        }

        @Override

        public String getDatabase() {

            return this.databaseName;

        }

        @Override

        public String getSchema() {

            return this.schemaName;

        }

        @Override

        public String getName() {

            return this.tableName;

        }

        @Override

        public boolean has_schema() {

            if( !supportSchemas() ) {

                return false;

            }

            return !StringUtils.isEmpty(this.schemaName);

        }

        @Override

        public boolean has_database() {

            return !StringUtils.isEmpty(this.databaseName);

        }

        @Override

        public String toString() {

            if( this.has_database()) {

                if( this.has_schema()) {

                    return identifier(this.databaseName) + "." + 

                           identifier(this.schemaName) + "." + 

                           identifier(this.tableName);

                }

            } else {

                if( this.has_schema()) {

                    return identifier(this.schemaName) + "." + 

                           identifier(this.tableName);

                }                

            }

            return identifier(this.tableName);

        }

    }

    public class CountBuilderBase extends AbstractValue implements CountBuilder {

        protected Value value;

        protected boolean distinct;

        protected boolean all ;

        public CountBuilderBase() {

            this.value = null;

            this.distinct = false;

            this.all = false;

        }

        @Override

        public CountBuilder all() {

            this.all = true;

            return this;

        }

        @Override

        public CountBuilder column(Value value) {

            this.value = value;

            return this;

        }

        @Override

        public CountBuilder distinct() {

            this.distinct = true;

            return this;

        }

        @Override

        public String toString() {

            if( this.all ) {

                return MessageFormat.format(

                    config.getString(SQLConfig.count),

                    "*"

                );

            }

            if( this.distinct ) {

                return MessageFormat.format(

                    config.getString(SQLConfig.count_distinct),

                    value.toString()

                );

            }

            return MessageFormat.format(

                config.getString(SQLConfig.count),

                value.toString()

            );

        }

    }

    public class FromBuilderBase implements FromBuilder {

        protected TableNameBuilder tableName= null;

        private String subquery = null;

        private String passthrough = null;

        @Override

        public TableNameBuilder table() {

            if( tableName == null ) {

                this.tableName = createTableNameBuilder();

            }

            return this.tableName;

        }

        @Override

        public void accept(Visitor visitor, VisitorFilter filter) {

            if( filter.accept(this) ) {

                visitor.visit(this);

            }

            if( this.tableName != null ) {

                this.tableName.accept(visitor, filter);

            }

        }

        @Override

        public FromBuilder custom(String passthrough) {

            this.passthrough = passthrough;

            return this;

        }

        @Override

        public FromBuilder subquery(String subquery) {

            this.subquery = subquery;

            return this;

        }

        @Override

        public String toString() {

            if( ! StringUtils.isEmpty(passthrough) ) {

                return passthrough;

            }

            if( ! StringUtils.isEmpty(subquery) ) {

                return "( " + this.subquery + ") as _subquery_alias_ ";

            }

            return this.tableName.toString();

        }

    }

    public class SelectColumnBuilderBase implements SelectColumnBuilder {

        private Variable name = null;

        private String alias = null;

        private Value value = null;

        private boolean asGeometry = false;

        @Override

        public void accept(Visitor visitor, VisitorFilter filter) {

            if( filter.accept(this) ) {

                visitor.visit(this);

            }

            if( this.name != null ) {

                this.name.accept(visitor, filter);

            }

            if( this.value != null ) {

                this.value.accept(visitor, filter);

            }

        }

        @Override

        public SelectColumnBuilder name(String name) {

            String quote = config.getString(Config.quote_for_identifiers);

            if (name.startsWith(quote)) {

                // Remove quotes

                name = name.substring(1, name.length() - 1);

            }

            this.name = variable(name);

            this.value = null;

            this.asGeometry = false;

            return this;

        }

        @Override

        public SelectColumnBuilder all() {

            this.name = null;

            this.value = custom("*");

            this.asGeometry = false;

            return this;

        }

        @Override

        public SelectColumnBuilder as_geometry() {

            this.asGeometry = true;

            return this;

        }

        @Override

        public SelectColumnBuilder value(Value value) {

            this.value = value;

            this.name = null;

            return this;

        }

        @Override

        public SelectColumnBuilder as(String alias) {

            this.alias = alias;

            return this;

        }

        @Override

        public String getName() {

            return this.name.getName();

        }

        @Override

        public String getAlias() {

            return this.alias;

        }

        @Override

        public String getValue() {

            return this.alias;

        }

        @Override

        public String toString() {

            StringBuilder builder = new StringBuilder();

            if( this.asGeometry ) {

                builder.append(getAsGeometry(this.name).toString());

            } else {

                if( this.name != null ) {

                    builder.append(this.name.toString());

                } else {

                    builder.append(this.value.toString());

                }

            }

            if( this.alias != null ) {

                builder.append(" AS ");

                builder.append(identifier(this.alias));

            }

            return builder.toString();

        }

    }

    public class OrderByBuilderBase implements OrderByBuilder {

        protected String value;

        protected String custom;

        protected boolean ascending;

        public OrderByBuilderBase() {

            this.ascending = true;

        }

        @Override

        public void accept(Visitor visitor, VisitorFilter filter) {

            if( filter.accept(this) ) {

                visitor.visit(this);

            }

        }

        @Override

        public OrderByBuilder column(String name) {

            this.value = name;

            return this;

        }

        @Override

        public OrderByBuilder custom(String order) {

            this.custom = order;

            return this;

        }

        @Override

        public OrderByBuilder ascending() {

            this.ascending = true;

            return this;

        }

        @Override

        public OrderByBuilder ascending(boolean asc) {

            this.ascending = asc;

            return this;

        }

        @Override

        public OrderByBuilder descending() {

            this.ascending = false;

            return this;

        }

        @Override

        public String toString() {

            if( !StringUtils.isEmpty(this.custom) ) {

                return this.custom;

            }

            if( this.ascending ) {

                return identifier(this.value) + " ASC";

            }

            return identifier(this.value) + " DESC";

        }

    }

    public class SelectBuilderBase implements SelectBuilder {

        protected FromBuilder from;

        protected ExpressionBuilder where;

        protected long limit = -1;

        protected long offset = -1;

        protected List<SelectColumnBuilder> columns;

        protected List<OrderByBuilder> order_by;

        protected boolean distinct;

        public SelectBuilderBase() {

            this.columns = new ArrayList<>();

            this.distinct = false;

        }

        @Override

        public void accept(Visitor visitor, VisitorFilter filter) {

            if( filter.accept(this) ) {

                visitor.visit(this);

            }

            for (SelectColumnBuilder column : columns) {

                column.accept(visitor,filter);

            }

            if( this.has_from() ) {

                this.from.accept(visitor,filter);

            }

            if( this.has_where() ) {

                this.where.accept(visitor,filter);

            }

            if( this.has_order_by() ) {

                for (OrderByBuilder order : order_by) {

                    order.accept(visitor,filter);

                }

            }

        }

        @Override

        public SelectBuilder distinct() {

            this.distinct = true;

            return this;

        }

        @Override

        public SelectColumnBuilder column() {

            SelectColumnBuilder builder = createSelectColumnBuilder();

            this.columns.add(builder);

            return builder;

        }

        @Override

        public boolean has_column(String name) {

            for (SelectColumnBuilder column : columns) {

                if( name.equals(column.getName()) ) {

                    return true;

                }

            }

            return false;

        }

        @Override

        public FromBuilder from() {

            if (this.from == null) {

                this.from = createFromBuilder();