yosql-models/yosql-models-immutables/src/main/java/wtf/metio/yosql/models/immutables/SqlStatement.java

   1 /*
   2  * This file is part of yosql. It is subject to the license terms in the LICENSE file found in the top-level
   3  * directory of this distribution and at https://creativecommons.org/publicdomain/zero/1.0/. No part of yosql,
   4  * including this file, may be copied, modified, propagated, or distributed except according to the terms contained
   5  * in the LICENSE file.
   6  */
   7 package wtf.metio.yosql.models.immutables;
   8
   9 import org.immutables.value.Value;
  10 import wtf.metio.yosql.internals.jdk.Buckets;
  11 import wtf.metio.yosql.models.configuration.ResultRowConverter;
  12 import wtf.metio.yosql.models.configuration.ReturningMode;
  13 import wtf.metio.yosql.models.configuration.SqlStatementType;
  14
  15 import java.nio.file.Path;
  16 import java.util.Comparator;
  17 import java.util.List;
  18 import java.util.stream.Stream;
  19
  20 /**
  21  * Encapsulates everything we know about a single SQL statement.
  22  */
  23 @Value.Immutable
  24 public interface SqlStatement {
  25
  26     //region builders
  27
  28     static ImmutableSqlStatement.SourcePathBuildStage builder() {
  29         return ImmutableSqlStatement.builder();
  30     }
  31
  32     //endregion
  33
  34     //region utils
  35
  36     static Stream<ResultRowConverter> resultConverters(
  37             final List<SqlStatement> statements,
  38             final ResultRowConverter defaultConverter) {
  39         return statements.stream()
  40                 .map(SqlStatement::getConfiguration)
  41                 .filter(SqlStatement::requiresConverter)
  42                 .map(config -> config.resultRowConverter().orElse(defaultConverter))
  43                 .sorted(Comparator.comparing((ResultRowConverter converter) -> converter.alias().orElse(""))
  44                         .thenComparing(converter -> converter.converterType().orElse(""))
  45                         .thenComparing(converter -> converter.resultType().orElse(""))
  46                         .thenComparing(converter -> converter.methodName().orElse("")))
  47                 .distinct();
  48     }
  49
  50     private static boolean requiresConverter(final SqlConfiguration configuration) {
  51         return configuration.returningMode()
  52                 .map(mode -> ReturningMode.NONE != mode)
  53                 .orElse(Boolean.FALSE);
  54     }
  55
  56     //endregion
  57
  58     /**
  59      * @return The file system path to the source file of this SQL statement.
  60      */
  61     Path getSourcePath();
  62
  63     /**
  64      * @return The parsed configuration of this SQL statement.
  65      */
  66     SqlConfiguration getConfiguration();
  67
  68     /**
  69      * @return The raw SQL statement.
  70      */
  71     String getRawStatement();
  72
  73     //region derived
  74
  75     @Value.Lazy
  76     default String getName() {
  77         return getConfiguration().name().orElseThrow();
  78     }
  79
  80     @Value.Lazy
  81     default String getRepositoryClass() {
  82         return getConfiguration().repository().orElseThrow();
  83     }
  84
  85     @Value.Lazy
  86     default String getRepositoryInterface() {
  87         return getConfiguration().repositoryInterface().orElse("");
  88     }
  89
  90     @Value.Lazy
  91     default boolean isReading() {
  92         return getConfiguration().type()
  93                 .map(type -> SqlStatementType.READING == type)
  94                 .orElse(Boolean.FALSE);
  95     }
  96
  97     @Value.Lazy
  98     default boolean isWriting() {
  99         return getConfiguration().type()
 100                 .map(type -> SqlStatementType.WRITING == type)
 101                 .orElse(Boolean.FALSE);
 102     }
 103
 104     @Value.Lazy
 105     default boolean isCalling() {
 106         return getConfiguration().type()
 107                 .map(type -> SqlStatementType.CALLING == type)
 108                 .orElse(Boolean.FALSE);
 109     }
 110
 111     @Value.Lazy
 112     default boolean executeWriteBatch() {
 113         return isWriting() &&
 114                 getConfiguration().executeBatch().orElse(Boolean.FALSE) &&
 115                 Buckets.hasEntries(getConfiguration().parameters());
 116     }
 117
 118     @Value.Lazy
 119     default boolean executeReadOnce() {
 120         return isReading() && getConfiguration().executeOnce().orElse(Boolean.FALSE);
 121     }
 122
 123     @Value.Lazy
 124     default boolean executeCallOnce() {
 125         return isCalling() && getConfiguration().executeOnce().orElse(Boolean.FALSE);
 126     }
 127
 128     @Value.Lazy
 129     default boolean executeWriteOnce() {
 130         return isWriting() && getConfiguration().executeOnce().orElse(Boolean.FALSE);
 131     }
 132
 133     //endregion
 134
 135 }