src/jdk.incubator.adba/share/classes/jdk/incubator/sql2/DataSource.java
author lancea
Mon, 09 Jul 2018 15:09:06 -0400
branchJDK-8188051-branch
changeset 56824 62e92191354d
parent 56797 fb523d4d9185
child 56997 c9cbac2979fb
permissions -rw-r--r--
JDK-8188051-branch latest 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;
56824
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
    31
import java.util.function.LongConsumer;
56380
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    32
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    33
/**
56824
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
    34
 * Uses the builder pattern to get a {@link Session}. A {@link DataSource#getSession}
56380
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    35
 * method is provided as a convenience.
56475
e700edfac7ad JDK-8188051-branch: Updates to sync with AOJ
lancea
parents: 56380
diff changeset
    36
 * 
e700edfac7ad JDK-8188051-branch: Updates to sync with AOJ
lancea
parents: 56380
diff changeset
    37
 * Implementations must be thread safe.
56380
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    38
 */
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    39
public interface DataSource
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    40
        extends AutoCloseable {
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
  /**
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    43
   * 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
    44
   * immutable once configured. No property can be set more than once. No 
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    45
   * property can be set after {@link build} is called. 
56797
fb523d4d9185 JDK-8188051-branch updates
lancea
parents: 56475
diff changeset
    46
   * 
fb523d4d9185 JDK-8188051-branch updates
lancea
parents: 56475
diff changeset
    47
   * ISSUE: Probably need property(DataSourceProperty prop, Object value).
56380
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    48
   */
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    49
  public interface Builder {
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
    /**
56824
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
    52
     * Specify a property and its value for the built {@link DataSource}.
56380
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    53
     *
56824
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
    54
     * @param p {@link DataSourceProperty} to set. Not {@code null}.
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
    55
     * @param v value for the property
56380
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    56
     * @return this {@link Builder}
56824
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
    57
     * @throws IllegalArgumentException if {@code p.validate(v)} does not return
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
    58
     * true, if this method has already been called with the property
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
    59
     * {@code p}, or the implementation does not support the 
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
    60
     * {@link DataSourceProperty}.
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
    61
     */
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
    62
    public Builder property(DataSourceProperty p, Object v);
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
    63
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
    64
    /**
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
    65
     * A convenience method for setting the {@link AdbaSessionProperty#URL}.
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
    66
     *
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
    67
     * @param url the value to be set for {@link AdbaSessionProperty#URL}
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
    68
     * @return this {@link Builder}
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
    69
     * @see sessionProperty
56380
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
    public default Builder url(String url) {
56824
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
    72
      return sessionProperty(AdbaSessionProperty.URL, url);
56380
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    73
    }
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
    /**
56824
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
    76
     * A convenience method for setting the {@link AdbaSessionProperty#USER}.
56380
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    77
     *
56824
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
    78
     * @param name the value to be set for {@link AdbaSessionProperty#USER}
56380
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    79
     * @return this {@link Builder}
56824
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
    80
     * @see sessionProperty
56380
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
    public default Builder username(String name) {
56824
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
    83
      return sessionProperty(AdbaSessionProperty.USER, name);
56380
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    84
    }
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    85
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    86
    /**
56824
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
    87
     * A convenience method for setting the {@link AdbaSessionProperty#PASSWORD}.
56380
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    88
     *
56824
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
    89
     * @param password the value to be set for {@link AdbaSessionProperty#PASSWORD}
56380
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    90
     * @return this {@link Builder}
56824
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
    91
     * @see sessionProperty
56380
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    92
     */
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    93
    public default Builder password(String password) {
56824
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
    94
      return sessionProperty(AdbaSessionProperty.PASSWORD, password);
56380
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
    95
    }
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
    /**
56824
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
    98
     * Specify the value of a {@link Session} property that will be set by default on
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
    99
     * all {@link Session}s produced by this {@link DataSource}. A different value can be set
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
   100
     * for a particular {@link Session} via {@link Session.Builder#property}.
56380
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   101
     *
56824
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
   102
     * @param property the {@link SessionProperty} to be set. May not be {@code null}.
56380
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   103
     * @param value the value to be set for {@code property}
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   104
     * @return this {@link Builder}
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   105
     * @throws IllegalArgumentException if {@code property.validate(value)} does not
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   106
     * 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
   107
     * this property has been specified previously to this method or
56824
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
   108
     * {@link sessionProperty} or {@link registerSessionProperty}.
56380
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   109
     * @throws IllegalStateException if {@link build} has previously been called.
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   110
     */
56824
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
   111
    public Builder defaultSessionProperty(SessionProperty property, Object value);
56380
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   112
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   113
    /**
56824
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
   114
     * Specify the value of a {@link Session} property that will be set on
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
   115
     * all {@link Session}s produced by the built {@link DataSource}.
56380
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   116
     * Attempting to set a different value via
56824
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
   117
     * {@link Session.Builder#property} will throw
56380
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   118
     * {@link IllegalArgumentException}.
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   119
     *
56824
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
   120
     * @param property the {@link SessionProperty} to set. May not be
56380
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   121
     * {@code null}.
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   122
     * @param value the value to set as the default for {@code property}
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   123
     * @return this {@link Builder}
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   124
     * @throws IllegalArgumentException if {@code property.validate(value)} does
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   125
     * not return {@code true}. If it throws an {@link Exception} that
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   126
     * {@link Exception} is the cause. Or if this property has been specified
56824
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
   127
     * previously to this method or {@link defaultSessionProperty} or
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
   128
     * {@link registerSessionProperty}.
56380
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   129
     * @throws IllegalStateException if {@link build} has previously been
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   130
     * called.
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   131
     */
56824
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
   132
    public Builder sessionProperty(SessionProperty property, Object value);
56380
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   133
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
     * Make a user defined property known to the implementation. One reason to
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   136
     * 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
   137
     * {@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
   138
     * set the default value. Convenience method.
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   139
     *
56824
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
   140
     * @param property the {@link SessionProperty} to make known. May not be
56380
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   141
     * {@code null}.
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   142
     * @return this Builder
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   143
     * @throws IllegalArgumentException if this property has been specified
56824
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
   144
     * previously to this method or {@link sessionProperty} or
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
   145
     * {@link defaultSessionProperty}.
56380
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   146
     * @throws IllegalStateException if {@link build} has previously been
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   147
     * called.
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   148
     */
56824
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
   149
    public default Builder registerSessionProperty(SessionProperty property) {
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
   150
      return defaultSessionProperty(property, property.defaultValue());
56380
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   151
    }
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   152
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   153
    /**
56797
fb523d4d9185 JDK-8188051-branch updates
lancea
parents: 56475
diff changeset
   154
     * Provide a method that the built {@link DataSource} will call to control the
56824
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
   155
     * rate of {@link Session} creations. The built
56797
fb523d4d9185 JDK-8188051-branch updates
lancea
parents: 56475
diff changeset
   156
     * {@link DataSource} will call {@code request} with a positive argument
56824
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
   157
     * when the {@link DataSource} is able to accept more calls to
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
   158
     * {@link DataSource#builder}. The difference between
56797
fb523d4d9185 JDK-8188051-branch updates
lancea
parents: 56475
diff changeset
   159
     * the sum of all arguments passed to {@code request} and the number of
fb523d4d9185 JDK-8188051-branch updates
lancea
parents: 56475
diff changeset
   160
     * calls to {@link DataSource#builder} is the
fb523d4d9185 JDK-8188051-branch updates
lancea
parents: 56475
diff changeset
   161
     * <i>demand</i>. The demand must always be non-negative. If a call is made to
56824
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
   162
     * {@link DataSource#builder} that would make the demand negative, that call 
56797
fb523d4d9185 JDK-8188051-branch updates
lancea
parents: 56475
diff changeset
   163
     * throws {@link IllegalStateException}. If {@code requestHook} is not called,
fb523d4d9185 JDK-8188051-branch updates
lancea
parents: 56475
diff changeset
   164
     * the demand is defined to be infinite.
fb523d4d9185 JDK-8188051-branch updates
lancea
parents: 56475
diff changeset
   165
     * 
fb523d4d9185 JDK-8188051-branch updates
lancea
parents: 56475
diff changeset
   166
     * <p>
56824
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
   167
     * Since the user thread is never blocked, a user thread could in theory 
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
   168
     * create, attach, use, and close {@link Session}s faster than the underlying
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
   169
     * implementation can process the submitted work. At some point work would
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
   170
     * start timing out or Java would run out of memory to store the queued
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
   171
     * {@link Operation}s. This is a poor way address the issue. This method 
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
   172
     * allows user code to get feedback from the {@link DataSource} as to whether
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
   173
     * the {@link DataSource} can accept more work.
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
   174
     * </p>
56797
fb523d4d9185 JDK-8188051-branch updates
lancea
parents: 56475
diff changeset
   175
     *
fb523d4d9185 JDK-8188051-branch updates
lancea
parents: 56475
diff changeset
   176
     * @param request accepts calls to increase the demand. Not null.
fb523d4d9185 JDK-8188051-branch updates
lancea
parents: 56475
diff changeset
   177
     * @return this {@link Builder}
fb523d4d9185 JDK-8188051-branch updates
lancea
parents: 56475
diff changeset
   178
     * @throws IllegalStateException if this method has been called previously
fb523d4d9185 JDK-8188051-branch updates
lancea
parents: 56475
diff changeset
   179
     */
56824
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
   180
    public Builder requestHook(LongConsumer request);
56797
fb523d4d9185 JDK-8188051-branch updates
lancea
parents: 56475
diff changeset
   181
fb523d4d9185 JDK-8188051-branch updates
lancea
parents: 56475
diff changeset
   182
    /**
56380
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   183
     * Return a DataSource configured as specified. 
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   184
     *
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   185
     * @return a configured {@link DataSource}. Not {@code null}.
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   186
     * @throws IllegalArgumentException if unable to return a {@link DataSource} due to
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   187
     * problems with the configuration such is missing or conflicting properties.
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
    public DataSource build();
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   190
  }
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
  /**
56824
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
   193
   * Returns a {@link Session} builder. By default that builder will return
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
   194
   * {@link Session}s with the {@code SessionProperty}s specified when creating this
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
   195
   * DataSource. Default and unspecified {@link SessionProperty}s can be set with
56380
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   196
   * the returned builder.
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   197
   *
56824
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
   198
   * @return a new {@link Session} builder. Not {@code null}.
56797
fb523d4d9185 JDK-8188051-branch updates
lancea
parents: 56475
diff changeset
   199
   * @throws IllegalStateException if this {@link DataSource} is closed
56380
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   200
   */
56824
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
   201
  public Session.Builder builder();
56380
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   202
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   203
  /**
56824
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
   204
   * Returns a {@link Session} that has a submitted attach {@link Operation}. Convenience
56380
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   205
   * method for use with try with resources.
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   206
   *
56824
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
   207
   * @return a {@link Session}
56797
fb523d4d9185 JDK-8188051-branch updates
lancea
parents: 56475
diff changeset
   208
   * @throws IllegalStateException if this {@link DataSource} is closed
56380
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   209
   */
56824
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
   210
  public default Session getSession() {
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
   211
    return builder().build().attach();
56380
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
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   214
  /**
56824
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
   215
   * Returns a {@link Session} that has a submitted attach {@link Operation} with an error
56380
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   216
   * handler. Convenience method for use with try with resources. The error
56824
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
   217
   * handle handles errors in the attach {@link Operation}.
56380
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   218
   *
56824
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
   219
   * @param handler for errors in the attach {@link Operation}
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
   220
   * @return a {@link Session}
56797
fb523d4d9185 JDK-8188051-branch updates
lancea
parents: 56475
diff changeset
   221
   * @throws IllegalStateException if this {@link DataSource} is closed
56380
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   222
   */
56824
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
   223
  public default Session getSession(Consumer<Throwable> handler) {
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
   224
    return builder().build().attach(handler);
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
  
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   227
  /**
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   228
   * Translates a SQL string from the format specified by the format argument
56824
62e92191354d JDK-8188051-branch latest updates
lancea
parents: 56797
diff changeset
   229
   * to a format that can be used to create {@link Operation}s for the {@link Session}s
56380
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   230
   * provided by this {@link DataSource}. 
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   231
   * 
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   232
   * ISSUE: Just an idea
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   233
   * 
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   234
   * @param format not {@code null}
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   235
   * @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
   236
   * @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
   237
   * @throws IllegalArgumentException if the {@code format} is not supported or
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   238
   * if the {@link DataSource} cannot translate the SQL
56797
fb523d4d9185 JDK-8188051-branch updates
lancea
parents: 56475
diff changeset
   239
   * @throws IllegalStateException if this {@link DataSource} is closed
56380
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
  public default String translateSql(String format, String source) throws SqlException {
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   242
    throw new IllegalArgumentException("Unsupported format: \"" + format + "\"");
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   243
  }
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
  /**
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   246
   * 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
   247
   * 
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   248
   * ISSUE: Just an idea
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   249
   * 
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   250
   * @return an array of Strings each of which identifies a supported format
56797
fb523d4d9185 JDK-8188051-branch updates
lancea
parents: 56475
diff changeset
   251
   * @throws IllegalStateException if this {@link DataSource} is closed
56380
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   252
   */
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   253
  public default List<String> supportedTranslateSqlFormats() {
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   254
    return new LinkedList<>();
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   255
  }
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   256
  
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   257
  @Override
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   258
  public void close();
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   259
f06946e00a26 JDK-8188051-branch: add jdk.incubator.adba
lancea
parents:
diff changeset
   260
}