src/jdk.incubator.adba/share/classes/jdk/incubator/sql2/DataSource.java
author lancea
Wed, 20 Jun 2018 15:38:40 -0400
branchJDK-8188051-branch
changeset 56797 fb523d4d9185
parent 56475 e700edfac7ad
child 56824 62e92191354d
permissions -rwxr-xr-x
JDK-8188051-branch updates
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
56380
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
     1
/*
56475
e700edfac7ad JDK-8188051-branch: Updates to sync with AOJ
lancea
parents: 56380
diff changeset
     2
 * Copyright (c)  2017, 2018, Oracle and/or its affiliates. All rights reserved.
56380
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
     3
 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
     4
 *
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
     5
 * This code is free software; you can redistribute it and/or modify it
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
     6
 * under the terms of the GNU General Public License version 2 only, as
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
     7
 * published by the Free Software Foundation.  Oracle designates this
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
     8
 * particular file as subject to the "Classpath" exception as provided
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
     9
 * by Oracle in the LICENSE file that accompanied this code.
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    10
 *
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    11
 * This code is distributed in the hope that it will be useful, but WITHOUT
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    12
 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    13
 * FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    14
 * version 2 for more details (a copy is included in the LICENSE file that
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    15
 * accompanied this code).
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    16
 *
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    17
 * You should have received a copy of the GNU General Public License version
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    18
 * 2 along with this work; if not, write to the Free Software Foundation,
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    19
 * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    20
 *
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    21
 * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    22
 * or visit www.oracle.com if you need additional information or have any
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    23
 * questions.
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    24
 */
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    25
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    26
package jdk.incubator.sql2;
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    27
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    28
import java.util.LinkedList;
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    29
import java.util.List;
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    30
import java.util.function.Consumer;
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    31
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    32
/**
56797
fb523d4d9185 JDK-8188051-branch updates
lancea
parents: 56475
diff changeset
    33
 * Uses the builder pattern to get a {@link Connection}. A {@link DataSource#getConnection}
56380
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    34
 * method is provided as a convenience.
56475
e700edfac7ad JDK-8188051-branch: Updates to sync with AOJ
lancea
parents: 56380
diff changeset
    35
 * 
e700edfac7ad JDK-8188051-branch: Updates to sync with AOJ
lancea
parents: 56380
diff changeset
    36
 * Implementations must be thread safe.
56380
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    37
 */
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    38
public interface DataSource
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    39
        extends AutoCloseable {
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    40
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    41
  /**
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    42
   * Instances of this type are used to build {@link DataSource}s. This type is 
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    43
   * immutable once configured. No property can be set more than once. No 
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    44
   * property can be set after {@link build} is called. 
56797
fb523d4d9185 JDK-8188051-branch updates
lancea
parents: 56475
diff changeset
    45
   * 
fb523d4d9185 JDK-8188051-branch updates
lancea
parents: 56475
diff changeset
    46
   * ISSUE: Probably need property(DataSourceProperty prop, Object value).
56380
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    47
   */
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    48
  public interface Builder {
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    49
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    50
    /**
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    51
     * A convenience method for setting the {@link AdbaConnectionProperty#URL}.
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    52
     *
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    53
     * @param url the value to be set for {@link AdbaConnectionProperty#URL}
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    54
     * @return this {@link Builder}
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    55
     * @see connectionProperty
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    56
     */
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    57
    public default Builder url(String url) {
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    58
      return connectionProperty(AdbaConnectionProperty.URL, url);
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    59
    }
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    60
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    61
    /**
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    62
     * A convenience method for setting the {@link AdbaConnectionProperty#USER}.
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    63
     *
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    64
     * @param name the value to be set for {@link AdbaConnectionProperty#USER}
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    65
     * @return this {@link Builder}
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    66
     * @see connectionProperty
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    67
     */
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    68
    public default Builder username(String name) {
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    69
      return connectionProperty(AdbaConnectionProperty.USER, name);
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    70
    }
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    71
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    72
    /**
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    73
     * A convenience method for setting the {@link AdbaConnectionProperty#PASSWORD}.
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    74
     *
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    75
     * @param password the value to be set for {@link AdbaConnectionProperty#PASSWORD}
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    76
     * @return this {@link Builder}
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    77
     * @see connectionProperty
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    78
     */
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    79
    public default Builder password(String password) {
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    80
      return connectionProperty(AdbaConnectionProperty.PASSWORD, password);
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    81
    }
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    82
    
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    83
    /**
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    84
     * Specify the value of a {@link Connection} property that will be set by default on
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    85
     * all {@link Connection}s produced by this {@link DataSource}. A different value can be set
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    86
     * for a particular {@link Connection} via {@link Connection.Builder#property}.
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    87
     *
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    88
     * @param property the {@link ConnectionProperty} to be set. May not be {@code null}.
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    89
     * @param value the value to be set for {@code property}
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    90
     * @return this {@link Builder}
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    91
     * @throws IllegalArgumentException if {@code property.validate(value)} does not
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    92
     * return {@code true}. If it throws an {@link Exception} that {@link Exception} is the cause. Or if
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    93
     * this property has been specified previously to this method or
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    94
     * {@link connectionProperty} or {@link registerConnectionProperty}.
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    95
     * @throws IllegalStateException if {@link build} has previously been called.
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    96
     */
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    97
    public Builder defaultConnectionProperty(ConnectionProperty property, Object value);
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    98
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    99
    /**
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   100
     * Specify the value of a {@link Connection} property that will be set on
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   101
     * all {@link Connection}s produced by the built {@link DataSource}.
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   102
     * Attempting to set a different value via
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   103
     * {@link Connection.Builder#property} will throw
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   104
     * {@link IllegalArgumentException}.
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   105
     *
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   106
     * @param property the {@link ConnectionProperty} to set. May not be
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   107
     * {@code null}.
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   108
     * @param value the value to set as the default for {@code property}
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   109
     * @return this {@link Builder}
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   110
     * @throws IllegalArgumentException if {@code property.validate(value)} does
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   111
     * not return {@code true}. If it throws an {@link Exception} that
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   112
     * {@link Exception} is the cause. Or if this property has been specified
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   113
     * previously to this method or {@link defaultConnectionProperty} or
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   114
     * {@link registerConnectionProperty}.
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   115
     * @throws IllegalStateException if {@link build} has previously been
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   116
     * called.
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   117
     */
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   118
    public Builder connectionProperty(ConnectionProperty property, Object value);
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   119
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   120
    /**
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   121
     * Make a user defined property known to the implementation. One reason to
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   122
     * do this is so the default value of the property will be used. If the
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   123
     * {@link DataSource} doesn't know about the property then it cannot know to
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   124
     * set the default value. Convenience method.
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   125
     *
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   126
     * @param property the {@link ConnectionProperty} to make known. May not be
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   127
     * {@code null}.
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   128
     * @return this Builder
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   129
     * @throws IllegalArgumentException if this property has been specified
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   130
     * previously to this method or {@link connectionProperty} or
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   131
     * {@link defaultConnectionProperty}.
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   132
     * @throws IllegalStateException if {@link build} has previously been
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   133
     * called.
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   134
     */
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   135
    public default Builder registerConnectionProperty(ConnectionProperty property) {
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   136
      return defaultConnectionProperty(property, property.defaultValue());
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   137
    }
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   138
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   139
    /**
56797
fb523d4d9185 JDK-8188051-branch updates
lancea
parents: 56475
diff changeset
   140
     * Provide a method that the built {@link DataSource} will call to control the
fb523d4d9185 JDK-8188051-branch updates
lancea
parents: 56475
diff changeset
   141
     * rate of {@link DataSource#connectOperation} submissions. The built
fb523d4d9185 JDK-8188051-branch updates
lancea
parents: 56475
diff changeset
   142
     * {@link DataSource} will call {@code request} with a positive argument
fb523d4d9185 JDK-8188051-branch updates
lancea
parents: 56475
diff changeset
   143
     * when the {@link DataSource} is able to accept more
fb523d4d9185 JDK-8188051-branch updates
lancea
parents: 56475
diff changeset
   144
     * {@link DataSource#connectOperation} submissions. The difference between
fb523d4d9185 JDK-8188051-branch updates
lancea
parents: 56475
diff changeset
   145
     * the sum of all arguments passed to {@code request} and the number of
fb523d4d9185 JDK-8188051-branch updates
lancea
parents: 56475
diff changeset
   146
     * calls to {@link DataSource#builder} is the
fb523d4d9185 JDK-8188051-branch updates
lancea
parents: 56475
diff changeset
   147
     * <i>demand</i>. The demand must always be non-negative. If a call is made to
fb523d4d9185 JDK-8188051-branch updates
lancea
parents: 56475
diff changeset
   148
     * {@link DataSource#builder} that would make the demand negative that call 
fb523d4d9185 JDK-8188051-branch updates
lancea
parents: 56475
diff changeset
   149
     * throws {@link IllegalStateException}. If {@code requestHook} is not called,
fb523d4d9185 JDK-8188051-branch updates
lancea
parents: 56475
diff changeset
   150
     * the demand is defined to be infinite.
fb523d4d9185 JDK-8188051-branch updates
lancea
parents: 56475
diff changeset
   151
     * 
fb523d4d9185 JDK-8188051-branch updates
lancea
parents: 56475
diff changeset
   152
     * <p>
fb523d4d9185 JDK-8188051-branch updates
lancea
parents: 56475
diff changeset
   153
     * An implementation may choose to delay detection of insufficient demand. 
fb523d4d9185 JDK-8188051-branch updates
lancea
parents: 56475
diff changeset
   154
     * Instead of checking when {@link DataSource#builder} is called an 
fb523d4d9185 JDK-8188051-branch updates
lancea
parents: 56475
diff changeset
   155
     * implementation may choose to check at some later point in Connection 
fb523d4d9185 JDK-8188051-branch updates
lancea
parents: 56475
diff changeset
   156
     * creation such as {@link Connection.Builder.build} or 
fb523d4d9185 JDK-8188051-branch updates
lancea
parents: 56475
diff changeset
   157
     * {@code Connection#connectOperation().submit()} or even later. In any case
fb523d4d9185 JDK-8188051-branch updates
lancea
parents: 56475
diff changeset
   158
     * an implementation must throw IllegalStateException before allocating
fb523d4d9185 JDK-8188051-branch updates
lancea
parents: 56475
diff changeset
   159
     * or waiting to allocate scarce resources if the demand is negative.</p>
fb523d4d9185 JDK-8188051-branch updates
lancea
parents: 56475
diff changeset
   160
     *
fb523d4d9185 JDK-8188051-branch updates
lancea
parents: 56475
diff changeset
   161
     * @param request accepts calls to increase the demand. Not null.
fb523d4d9185 JDK-8188051-branch updates
lancea
parents: 56475
diff changeset
   162
     * @return this {@link Builder}
fb523d4d9185 JDK-8188051-branch updates
lancea
parents: 56475
diff changeset
   163
     * @throws IllegalStateException if this method has been called previously
fb523d4d9185 JDK-8188051-branch updates
lancea
parents: 56475
diff changeset
   164
     */
fb523d4d9185 JDK-8188051-branch updates
lancea
parents: 56475
diff changeset
   165
    public Builder requestHook(Consumer<Long> request);
fb523d4d9185 JDK-8188051-branch updates
lancea
parents: 56475
diff changeset
   166
fb523d4d9185 JDK-8188051-branch updates
lancea
parents: 56475
diff changeset
   167
    /**
56380
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   168
     * Return a DataSource configured as specified. 
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   169
     *
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   170
     * @return a configured {@link DataSource}. Not {@code null}.
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   171
     * @throws IllegalArgumentException if unable to return a {@link DataSource} due to
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   172
     * problems with the configuration such is missing or conflicting properties.
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   173
     */
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   174
    public DataSource build();
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   175
  }
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   176
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   177
  /**
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   178
   * Returns a {@link Connection} builder. By default that builder will return
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   179
   * {@link Connection}s with the {@code ConnectionProperty}s specified when creating this
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   180
   * DataSource. Default and unspecified {@link ConnectionProperty}s can be set with
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   181
   * the returned builder.
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   182
   *
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   183
   * @return a new {@link Connection} builder. Not {@code null}.
56797
fb523d4d9185 JDK-8188051-branch updates
lancea
parents: 56475
diff changeset
   184
   * @throws IllegalStateException if this {@link DataSource} is closed
56380
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   185
   */
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   186
  public Connection.Builder builder();
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   187
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   188
  /**
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   189
   * Returns a {@link Connection} that has a submitted connect {@link Operation}. Convenience
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   190
   * method for use with try with resources.
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   191
   *
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   192
   * @return a {@link Connection}
56797
fb523d4d9185 JDK-8188051-branch updates
lancea
parents: 56475
diff changeset
   193
   * @throws IllegalStateException if this {@link DataSource} is closed
56380
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   194
   */
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   195
  public default Connection getConnection() {
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   196
    return builder().build().connect();
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   197
  }
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   198
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   199
  /**
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   200
   * Returns a {@link Connection} that has a submitted connect {@link Operation} with an error
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   201
   * handler. Convenience method for use with try with resources. The error
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   202
   * handle handles errors in the connect {@link Operation}.
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   203
   *
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   204
   * @param handler for errors in the connect {@link Operation}
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   205
   * @return a {@link Connection}
56797
fb523d4d9185 JDK-8188051-branch updates
lancea
parents: 56475
diff changeset
   206
   * @throws IllegalStateException if this {@link DataSource} is closed
56380
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   207
   */
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   208
  public default Connection getConnection(Consumer<Throwable> handler) {
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   209
    return builder().build().connect(handler);
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   210
  }
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   211
  
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   212
  /**
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   213
   * Translates a SQL string from the format specified by the format argument
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   214
   * to a format that can be used to create {@link Operation}s for the {@link Connection}s
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   215
   * provided by this {@link DataSource}. 
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   216
   * 
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   217
   * ISSUE: Just an idea
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   218
   * 
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   219
   * @param format not {@code null}
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   220
   * @param source SQL in the format specified by {@code format}. Not {@code null}.
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   221
   * @return SQL in the format supported by this {@link DataSource}. Not {@code null}.
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   222
   * @throws IllegalArgumentException if the {@code format} is not supported or
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   223
   * if the {@link DataSource} cannot translate the SQL
56797
fb523d4d9185 JDK-8188051-branch updates
lancea
parents: 56475
diff changeset
   224
   * @throws IllegalStateException if this {@link DataSource} is closed
56380
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   225
   */
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   226
  public default String translateSql(String format, String source) throws SqlException {
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   227
    throw new IllegalArgumentException("Unsupported format: \"" + format + "\"");
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   228
  }
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   229
  
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   230
  /**
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   231
   * Return a list of the source formats accepted by the {@link translateSql} method.
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   232
   * 
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   233
   * ISSUE: Just an idea
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   234
   * 
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   235
   * @return an array of Strings each of which identifies a supported format
56797
fb523d4d9185 JDK-8188051-branch updates
lancea
parents: 56475
diff changeset
   236
   * @throws IllegalStateException if this {@link DataSource} is closed
56380
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   237
   */
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   238
  public default List<String> supportedTranslateSqlFormats() {
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   239
    return new LinkedList<>();
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   240
  }
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   241
  
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   242
  @Override
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   243
  public void close();
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   244
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   245
}