Class SqlConnectOptions

    • Field Detail

      • DEFAULT_RECONNECT_ATTEMPTS

        public static final int DEFAULT_RECONNECT_ATTEMPTS
        See Also:
        Constant Field Values
      • DEFAULT_RECONNECT_INTERVAL

        public static final long DEFAULT_RECONNECT_INTERVAL
        See Also:
        Constant Field Values
      • DEFAULT_CACHE_PREPARED_STATEMENTS

        public static final boolean DEFAULT_CACHE_PREPARED_STATEMENTS
        See Also:
        Constant Field Values
      • DEFAULT_PREPARED_STATEMENT_CACHE_MAX_SIZE

        public static final int DEFAULT_PREPARED_STATEMENT_CACHE_MAX_SIZE
        See Also:
        Constant Field Values
      • DEFAULT_PREPARED_STATEMENT_CACHE_SQL_LIMIT

        public static final int DEFAULT_PREPARED_STATEMENT_CACHE_SQL_LIMIT
        See Also:
        Constant Field Values
      • DEFAULT_PREPARED_STATEMENT_CACHE_FILTER

        public static final java.util.function.Predicate<String> DEFAULT_PREPARED_STATEMENT_CACHE_FILTER
    • Constructor Detail

      • SqlConnectOptions

        public SqlConnectOptions()
      • SqlConnectOptions

        public SqlConnectOptions​(JsonObject json)
    • Method Detail

      • getHost

        public String getHost()
        Get the host for connecting to the server.
        Returns:
        the host
      • setHost

        public SqlConnectOptions setHost​(String host)
        Specify the host for connecting to the server.
        Parameters:
        host - the host to specify
        Returns:
        a reference to this, so the API can be used fluently
      • getPort

        public int getPort()
        Get the port for connecting to the server.
        Returns:
        the port
      • setPort

        public SqlConnectOptions setPort​(int port)
        Specify the port for connecting to the server.
        Parameters:
        port - the port to specify
        Returns:
        a reference to this, so the API can be used fluently
      • getUser

        public String getUser()
        Get the user account to be used for the authentication.
        Returns:
        the user
      • setUser

        public SqlConnectOptions setUser​(String user)
        Specify the user account to be used for the authentication.
        Parameters:
        user - the user to specify
        Returns:
        a reference to this, so the API can be used fluently
      • getPassword

        public String getPassword()
        Get the user password to be used for the authentication.
        Returns:
        the password
      • setPassword

        public SqlConnectOptions setPassword​(String password)
        Specify the user password to be used for the authentication.
        Parameters:
        password - the password to specify
        Returns:
        a reference to this, so the API can be used fluently
      • getDatabase

        public String getDatabase()
        Get the default database name for the connection.
        Returns:
        the database name
      • setDatabase

        public SqlConnectOptions setDatabase​(String database)
        Specify the default database for the connection.
        Parameters:
        database - the database name to specify
        Returns:
        a reference to this, so the API can be used fluently
      • getCachePreparedStatements

        public boolean getCachePreparedStatements()
        Get whether prepared statements cache is enabled.
        Returns:
        the value
      • setCachePreparedStatements

        public SqlConnectOptions setCachePreparedStatements​(boolean cachePreparedStatements)
        Set whether prepared statements cache should be enabled.
        Parameters:
        cachePreparedStatements - true if cache should be enabled
        Returns:
        a reference to this, so the API can be used fluently
      • getPreparedStatementCacheMaxSize

        public int getPreparedStatementCacheMaxSize()
        Get the maximum number of prepared statements that the connection will cache.
        Returns:
        the size
      • setPreparedStatementCacheMaxSize

        public SqlConnectOptions setPreparedStatementCacheMaxSize​(int preparedStatementCacheMaxSize)
        Set the maximum number of prepared statements that the connection will cache.
        Parameters:
        preparedStatementCacheMaxSize - the size to set
        Returns:
        a reference to this, so the API can be used fluently
      • getPreparedStatementCacheSqlFilter

        public java.util.function.Predicate<String> getPreparedStatementCacheSqlFilter()
        Get the predicate filtering prepared statements that the connection will cache.
        Returns:
        the current predicate
      • setPreparedStatementCacheSqlFilter

        public SqlConnectOptions setPreparedStatementCacheSqlFilter​(java.util.function.Predicate<String> predicate)
        Set a predicate filtering prepared statements that the connection will cache.

        The default predicate accepts predicate having query length < DEFAULT_PREPARED_STATEMENT_CACHE_SQL_LIMIT

        Parameters:
        predicate - the filter
      • setPreparedStatementCacheSqlLimit

        public SqlConnectOptions setPreparedStatementCacheSqlLimit​(int preparedStatementCacheSqlLimit)
        Set the maximum length of prepared statement SQL string that the connection will cache.

        This is an helper setting the setPreparedStatementCacheSqlFilter(Predicate).

        Parameters:
        preparedStatementCacheSqlLimit - the maximum length limit of SQL string to set
        Returns:
        a reference to this, so the API can be used fluently
      • getProperties

        public Map<String,​String> getProperties()
        Returns:
        the value of current connection properties
      • setProperties

        public SqlConnectOptions setProperties​(Map<String,​String> properties)
        Set properties for this client, which will be sent to server at the connection start.
        Parameters:
        properties - the value of properties to specify
        Returns:
        a reference to this, so the API can be used fluently
      • addProperty

        public SqlConnectOptions addProperty​(String key,
                                             String value)
        Add a property for this client, which will be sent to server at the connection start.
        Parameters:
        key - the value of property key
        value - the value of property value
        Returns:
        a reference to this, so the API can be used fluently
      • getTracingPolicy

        public TracingPolicy getTracingPolicy()
        Returns:
        the tracing policy
      • setTracingPolicy

        public SqlConnectOptions setTracingPolicy​(TracingPolicy tracingPolicy)
        Set the tracing policy for the client behavior when Vert.x has tracing enabled.
        Parameters:
        tracingPolicy - the tracing policy
        Returns:
        a reference to this, so the API can be used fluently
      • isUsingDomainSocket

        public boolean isUsingDomainSocket()
      • getReconnectAttempts

        public int getReconnectAttempts()
        Returns:
        the value of reconnect attempts
      • setReconnectAttempts

        public SqlConnectOptions setReconnectAttempts​(int attempts)
        Set the value of reconnect attempts
        Parameters:
        attempts - the maximum number of reconnect attempts
        Returns:
        a reference to this, so the API can be used fluently
      • getReconnectInterval

        public long getReconnectInterval()
        Returns:
        the value of reconnect interval
      • setReconnectInterval

        public SqlConnectOptions setReconnectInterval​(long interval)
        Set the reconnect interval
        Parameters:
        interval - the reconnect interval in ms
        Returns:
        a reference to this, so the API can be used fluently
      • getMetricsName

        public String getMetricsName()
        Returns:
        the metrics name identifying the reported metrics.
      • setMetricsName

        public SqlConnectOptions setMetricsName​(String metricsName)
        Set the metrics name identifying the reported metrics, useful for grouping metrics with the same name.
        Parameters:
        metricsName - the metrics name
        Returns:
        a reference to this, so the API can be used fluently
      • init

        protected void init()
        Initialize with the default options.
      • merge

        public SqlConnectOptions merge​(JsonObject other)
        Returns new options created after this object and merged with the other json config.
        Parameters:
        other - the other JSON object
        Returns:
        new options created after this object and merged with the other json config