git.basschouten.com Git - openhab-addons.git/blob

   1 /**
   2  * Copyright (c) 2010-2021 Contributors to the openHAB project
   3  *
   4  * See the NOTICE file(s) distributed with this work for additional
   5  * information.
   6  *
   7  * This program and the accompanying materials are made available under the
   8  * terms of the Eclipse Public License 2.0 which is available at
   9  * http://www.eclipse.org/legal/epl-2.0
  10  *
  11  * SPDX-License-Identifier: EPL-2.0
  12  */
  13 package org.openhab.persistence.jdbc.db;
  14
  15 import org.knowm.yank.Yank;
  16 import org.openhab.core.items.Item;
  17 import org.openhab.persistence.jdbc.dto.ItemVO;
  18 import org.openhab.persistence.jdbc.dto.ItemsVO;
  19 import org.openhab.persistence.jdbc.utils.StringUtilsExt;
  20 import org.slf4j.Logger;
  21 import org.slf4j.LoggerFactory;
  22
  23 /**
  24  * Extended Database Configuration class. Class represents
  25  * the extended database-specific configuration. Overrides and supplements the
  26  * default settings from JdbcBaseDAO. Enter only the differences to JdbcBaseDAO here.
  27  *
  28  * @author Helmut Lehmeyer - Initial contribution
  29  */
  30 public class JdbcHsqldbDAO extends JdbcBaseDAO {
  31     private final Logger logger = LoggerFactory.getLogger(JdbcHsqldbDAO.class);
  32
  33     /********
  34      * INIT *
  35      ********/
  36     public JdbcHsqldbDAO() {
  37         super();
  38         initSqlQueries();
  39         initSqlTypes();
  40         initDbProps();
  41     }
  42
  43     private void initSqlQueries() {
  44         logger.debug("JDBC::initSqlQueries: '{}'", this.getClass().getSimpleName());
  45         // http://hsqldb.org/doc/guide/builtinfunctions-chapt.html
  46         sqlPingDB = "SELECT 1 FROM INFORMATION_SCHEMA.SYSTEM_USERS";
  47         sqlGetDB = "SELECT DATABASE () FROM INFORMATION_SCHEMA.SYSTEM_USERS";
  48         sqlIfTableExists = "SELECT * FROM INFORMATION_SCHEMA.SYSTEM_TABLES WHERE TABLE_NAME='#searchTable#'";
  49         sqlCreateItemsTableIfNot = "CREATE TABLE IF NOT EXISTS #itemsManageTable# ( ItemId INT GENERATED BY DEFAULT AS IDENTITY (START WITH 1, INCREMENT BY 1) NOT NULL, #colname# #coltype# NOT NULL)";
  50         sqlCreateNewEntryInItemsTable = "INSERT INTO #itemsManageTable# (ItemName) VALUES ('#itemname#')";
  51         // Prevent error against duplicate time value
  52         // http://hsqldb.org/doc/guide/dataaccess-chapt.html#dac_merge_statement
  53         // SQL_INSERT_ITEM_VALUE = "INSERT INTO #tableName# (TIME, VALUE) VALUES( NOW(), CAST( ? as #dbType#) )";
  54         sqlInsertItemValue = "MERGE INTO #tableName# "
  55                 + "USING (VALUES #tablePrimaryValue#, CAST( ? as #dbType#)) temp (TIME, VALUE) ON (#tableName#.TIME=temp.TIME) "
  56                 + "WHEN NOT MATCHED THEN INSERT (TIME, VALUE) VALUES (temp.TIME, temp.VALUE)";
  57     }
  58
  59     /**
  60      * INFO: http://www.java2s.com/Code/Java/Database-SQL-JDBC/StandardSQLDataTypeswithTheirJavaEquivalents.htm
  61      */
  62     private void initSqlTypes() {
  63     }
  64
  65     /**
  66      * INFO: https://github.com/brettwooldridge/HikariCP
  67      */
  68     private void initDbProps() {
  69         // Properties for HikariCP
  70         databaseProps.setProperty("driverClassName", "org.hsqldb.jdbcDriver");
  71     }
  72
  73     /**************
  74      * ITEMS DAOs *
  75      **************/
  76     @Override
  77     public Integer doPingDB() {
  78         return Yank.queryScalar(sqlPingDB, Integer.class, null);
  79     }
  80
  81     @Override
  82     public ItemsVO doCreateItemsTableIfNot(ItemsVO vo) {
  83         String sql = StringUtilsExt.replaceArrayMerge(sqlCreateItemsTableIfNot,
  84                 new String[] { "#itemsManageTable#", "#colname#", "#coltype#", "#itemsManageTable#" },
  85                 new String[] { vo.getItemsManageTable(), vo.getColname(), vo.getColtype(), vo.getItemsManageTable() });
  86         logger.debug("JDBC::doCreateItemsTableIfNot sql={}", sql);
  87         Yank.execute(sql, null);
  88         return vo;
  89     }
  90
  91     @Override
  92     public Long doCreateNewEntryInItemsTable(ItemsVO vo) {
  93         String sql = StringUtilsExt.replaceArrayMerge(sqlCreateNewEntryInItemsTable,
  94                 new String[] { "#itemsManageTable#", "#itemname#" },
  95                 new String[] { vo.getItemsManageTable(), vo.getItemname() });
  96         logger.debug("JDBC::doCreateNewEntryInItemsTable sql={}", sql);
  97         return Yank.insert(sql, null);
  98     }
  99
 100     /*************
 101      * ITEM DAOs *
 102      *************/
 103     @Override
 104     public void doStoreItemValue(Item item, ItemVO vo) {
 105         vo = storeItemValueProvider(item, vo);
 106         String sql = StringUtilsExt.replaceArrayMerge(sqlInsertItemValue,
 107                 new String[] { "#tableName#", "#dbType#", "#tableName#", "#tablePrimaryValue#" }, new String[] {
 108                         vo.getTableName(), vo.getDbType(), vo.getTableName(), sqlTypes.get("tablePrimaryValue") });
 109         Object[] params = new Object[] { vo.getValue() };
 110         logger.debug("JDBC::doStoreItemValue sql={} value='{}'", sql, vo.getValue());
 111         Yank.execute(sql, params);
 112     }
 113
 114     /****************************
 115      * SQL generation Providers *
 116      ****************************/
 117
 118     /*****************
 119      * H E L P E R S *
 120      *****************/
 121
 122     /******************************
 123      * public Getters and Setters *
 124      ******************************/
 125 }