FWD » Core Development » Database

                 'udf/mariadb/guarded.sql', 

            String checkErrorFn = (useSQLUdfs ? udfSchema : "") + dialect.checkErrorFn();

            String initErrorFn = (useSQLUdfs ? udfSchema : "") + dialect.initErrorFn();

            if (useSQLUdfs)

      int pos = fn.lastIndexOf("_");

      if (pos > 0)

      {

         fn = fn.substring(0, pos);

      }

**     IAS 20230208          Dialect-specific error handler support.

import com.mchange.v2.c3p0.*;

   /** 

    * Get name of the checkError UDF. 

    * @return the name of the checkError UDF.  

    */ 

   public String checkErrorFn()

   {

      return "checkError";

   }

   /** 

    * Get name of the initError UDF. 

    * @return the name of the initError UDF.  

    */ 

   public String initErrorFn()

   {

      return "initError";

   }

    * Get c3p0 ConnectionCustomizer class for the dialect.

    * 

    * @param cfg 

    *        Database configuration.

    * @return c3p0 ConnectionCustomizer class for the dialect.

    */

   public Class<? extends AbstractConnectionCustomizer> connectionCustomizer(DatabaseConfig cfg)

   {

      return null;

   }

   /**

    * Activate error handler at the database side.

    * @param  conn 

    *         Database connection

    * @throws SQLException

    *         on error.

    */

   public void activateErrorHandler(Connection conn)

   throws SQLException

   {

   }

   /**

    * Reset error handler at the database side.

    * @param  conn 

    *         Database connection

    * @throws SQLException

    *         on error.

    */

   public void resetErrorHandler(Connection conn)

   throws SQLException

   {

   }

   /**

/*

** Module   : FWDMariaDBConnectionCustomizer

** Abstract : c3p0 connection customizer

**

** Copyright (c) 2023, Golden Code Development Corporation.

**

** -#- -I- --Date-- ---------------------------------------Description---------------------------------------

** 001 IAS 20230208 Created initial version.

*/

/*

** This program is free software: you can redistribute it and/or modify

** it under the terms of the GNU Affero General Public License as

** published by the Free Software Foundation, either version 3 of the

** License, or (at your option) any later version.

**

** This program is distributed in the hope that it will be useful,

** but WITHOUT ANY WARRANTY; without even the implied warranty of

** MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

** GNU Affero General Public License for more details.

**

** You may find a copy of the GNU Affero GPL version 3 at the following

** location: https://www.gnu.org/licenses/agpl-3.0.en.html

**

** Additional terms under GNU Affero GPL version 3 section 7:

**

**   Under Section 7 of the GNU Affero GPL version 3, the following additional

**   terms apply to the works covered under the License.  These additional terms

**   are non-permissive additional terms allowed under Section 7 of the GNU

**   Affero GPL version 3 and may not be removed by you.

**

**   0. Attribution Requirement.

**

**     You must preserve all legal notices or author attributions in the covered

**     work or Appropriate Legal Notices displayed by works containing the covered

**     work.  You may not remove from the covered work any author or developer

**     credit already included within the covered work.

**

**   1. No License To Use Trademarks.

**

**     This license does not grant any license or rights to use the trademarks

**     Golden Code, FWD, any Golden Code or FWD logo, or any other trademarks

**     of Golden Code Development Corporation. You are not authorized to use the

**     name Golden Code, FWD, or the names of any author or contributor, for

**     publicity purposes without written authorization.

**

**   2. No Misrepresentation of Affiliation.

**

**     You may not represent yourself as Golden Code Development Corporation or FWD.

**

**     You may not represent yourself for publicity purposes as associated with

**     Golden Code Development Corporation, FWD, or any author or contributor to

**     the covered work, without written authorization.

**

**   3. No Misrepresentation of Source or Origin.

**

**     You may not represent the covered work as solely your work.  All modified

**     versions of the covered work must be marked in a reasonable way to make it

**     clear that the modified work is not originating from Golden Code Development

**     Corporation or FWD.  All modified versions must contain the notices of

**     attribution required in this license.

*/

package com.goldencode.p2j.persist.dialect;

import java.sql.*;

import org.slf4j.*;

import com.goldencode.p2j.*;

import com.mchange.v2.c3p0.*;

/**

 * Customizes the connection to database by setting up the {@code use.java.udfs} and {@code fwd.version}

 * SQL configuration variable. 

 */

public class FWDMariaDBConnectionCustomizer 

extends AbstractConnectionCustomizer

{

   /** Logger */

   private static final Logger LOG = LoggerFactory.getLogger(FWDPostgreSQLConnectionCustomizer.class);

   /**

    * Called immediately after a {@code Connection} is acquired from the underlying database for 

    * incorporation into the pool.

    *

    * @param   c

    *          Connection to be customized.

    * @param   parentDataSourceIdentityToken

    *          The parent data source identity token.

    */

   @Override

   public void onAcquire(Connection c, String parentDataSourceIdentityToken)

   throws java.lang.Exception 

   {

      // The database session user should be able to create temporary tables

      // This can be granted by GRANT CREATE TEMPORARY TABLES ON *.* TO 'fwd_user'@'%';

      try

      {

         c.prepareStatement(

            "create temporary table if not exists "

            + "temp_error_stack("

            + "id integer not null auto_increment, "

            + "state boolean not null, "

            + "fwd_error_ctx text default @fwd_error_ctx, "

            + "PRIMARY KEY (id)"

            + ")"

         ).executeUpdate();

      }

      catch(SQLException e)

      {

         LOG.warn("Failed to customize connection", e);

      }

   }

}

** Module   : FWDPostgreSQLConnectionCustomizer.java

** Copyright (c) 2021-2023, Golden Code Development Corporation.

*      IAS 20230202 Renamed

public class FWDPostgreSQLConnectionCustomizer

   private static final Logger LOG = LoggerFactory.getLogger(FWDPostgreSQLConnectionCustomizer.class);

**     IAS 20230208 Added error handler support.

import com.mchange.v2.c3p0.*;

    * Get c3p0 ConnectionCustomizer class for the dialect.

    * @param <T>

    *        Customizer class  

    * @param cfg 

    *        Database configuration.

    * @return c3p0 ConnectionCustomizer class for the dialect.

    */

   @Override

   public Class<? extends AbstractConnectionCustomizer> connectionCustomizer(DatabaseConfig cfg)

   {

      return FWDMariaDBConnectionCustomizer.class;

   }

   /**

    * Activate error handler at the database side.

    * @param  conn 

    *         Database connection

    * @throws SQLException

    *         on error.

    */

   @Override

   public void activateErrorHandler(Connection conn)

   throws SQLException

   {

      conn.prepareCall("{ call activateErrorHandler()}").executeUpdate();

   }

   /**

    * Reset error handler at the database side.

    * @param  conn 

    *         Database connection

    * @throws SQLException

    *         on error.

    */

   @Override

   public void resetErrorHandler(Connection conn)

   throws SQLException

   {

      conn.prepareCall("{ call resetErrorHandler()}").executeUpdate();

   }

   /**

   /** 

    * Get name of the checkError UDF. 

    * @return the name of the checkError UDF.  

    */

   @Override

   public String checkErrorFn()

   {

      return "checkError_BB";

   }

   /** 

    * Get name of the initError UDF. 

    * @return the name of the initError UDF.  

    */ 

   @Override

   public String initErrorFn()

   {

      return "initError_B";

   }

**     IAS 20230208          Dialect-specific error handler support.

import com.mchange.v2.c3p0.*;

    * Get c3p0 ConnectionCustomizer class for the dialect.

    * @param <T>

    *        Customizer class  

    * @param cfg 

    *        Database configuration.

    * @return c3p0 ConnectionCustomizer class for the dialect.

    */

   @Override

   public Class<? extends AbstractConnectionCustomizer> connectionCustomizer(DatabaseConfig cfg)

   {

      return cfg.isUseJavaUDFs() ? null : FWDPostgreSQLConnectionCustomizer.class;

   }

   /**

**     IAS 20230208 Dialect-specific error handler support.

   /** 

    * Get name of the checkError UDF. 

    * @return the name of the checkError UDF.  

    */

   @Override

   public String checkErrorFn()

   {

      return "dbo.checkError_bb";

   }

   /** 

    * Get name of the initError UDF. 

    * @return the name of the initError UDF.  

    */ 

   @Override

   public String initErrorFn()

   {

      return "dbo.initError_b";

   }

**     IAS 20230208 Dialect-specific error handler support.

   /** The name of the checkError UDF with prepended dot */

   private final String _checkErrorFn;

   /** Flag indicating that the query contains error handling */

   private boolean containsErrorHandling = false;

      this._checkErrorFn = "." + dialect.checkErrorFn();

   /**

    * Checks if the query contains error handling.

    * 

    * @return  {@code true} if the query contains error handling.

    */

   public boolean containsErrorHandling()

   {

      return containsErrorHandling;

   }

                     if (text.equals(dialect.checkErrorFn()) || text.endsWith(_checkErrorFn))

                     {

                        containsErrorHandling = true;

                     }

** Copyright (c) 2019-2023, Golden Code Development Corporation.

**     IAS 20230208 Dialect-specific error handler support.

         Class<? extends AbstractConnectionCustomizer> customizer = 

                  DatabaseManager.getDialect(database).connectionCustomizer(cfg);

         if (ds.getConnectionCustomizerClassName() == null && customizer != null)

         {

            ds.setConnectionCustomizerClassName(customizer.getName());

         }

         if (!cfg.isUseJavaUDFs() )

** Copyright (c) 2019-2023, Golden Code Development Corporation.

**     IAS 20230208 Dialect-specific error handler support.

   /** Flag indicating that the query contains error handling */

   private boolean containsErrorHandling = false;

            this.containsErrorHandling = fql2sql.containsErrorHandling();

            sqlQuery = Session.createSQLQuery(sql, fql2sql.sessionAttrs(), 

                     fql2sql.getParameterPermutation()).

                     containsErrorHandling(containsErrorHandling);

**     IAS 20230208 Dialect-specific error handler support.

   /** Flag indicating that the query contains error handling */

   private boolean containsErrorHandling = false;

    * Set the value of the flag indicating that the query contains error handling.

    * @param value

    *        The new value of the flag;

    * @return <code>this</code>

    */

   public SQLQuery containsErrorHandling(boolean value)

   {

      this.containsErrorHandling = value;

      return this;

   }

   /**

         activateErrorHandler(session);

         return new ScrollableResults<T>(stmt, resultSet, rowStructure, session).

                    onClose(() -> {resetErrorHandler(session); return null;});

//      finally

//      {

//         resetErrorHandler(session);

//      }

         activateErrorHandler(session);

         return new ScrollableResults<T>(stmt, resultSet, rowStructure, session).

                  onClose(() -> {resetErrorHandler(session); return null;});

//      finally 

//      {

//         resetErrorHandler(session);

//      }

         activateErrorHandler(session);

         resetErrorHandler(session);

         activateErrorHandler(session);

         resetErrorHandler(session);

         activateErrorHandler(session);

         resetErrorHandler(session);

    * Activate error handler at the database side.

    * @param  session 

    *         Database session

    * @throws SQLException

    *         on error.

    * @throws PersistenceException 

    *         on error.

    */

   private void activateErrorHandler(Session session)

   throws SQLException, PersistenceException

   {

      if (!containsErrorHandling)

      {

         return;

      }

      Query.getDialect(session).activateErrorHandler(session.getConnection());  

   }

   /**

    * Reset error handler at the database side.

    * @param  session 

    *         Database session

    * @throws SQLException

    *         on error.

    * @throws PersistenceException 

    *         on error.

    */

   public void resetErrorHandler(Session session)

   throws PersistenceException

   {

      if (!containsErrorHandling)

      {

         return;

      }

      try

      {

         Query.getDialect(session).activateErrorHandler(session.getConnection());

      }

      catch (SQLException e)

      {

         throw new PersistenceException("Failed to reset error handler", e);

      }  

   }

   /**

** Copyright (c) 2019-2023, Golden Code Development Corporation.

**     IAS 20230208          Dialect-specific error handler support.

   /** On close hook*/

   private SandboxRun<Void> onClose = () -> null;

    * Set on close hook

    * @param hook

    *        new hook;

    * @return <code>this</code>

    */

   public ScrollableResults<T> onClose(SandboxRun<Void> hook)

   {

      this.onClose = hook;

      return this;

   }

   /**

    * @param i 

    *        column number

    * @param tClass 

    *        column 

   public T get(int i, Class<T>tClass)

      execute(() -> { stmt.close(); onClose.run(); return null; }, null);

** Abstract : 'Native' versions of the ErrorHandler-based Java UDFs (MariaDB version)

** Copyright (c) 2023, Golden Code Development Corporation.

** 001 IAS 20230208 Created initial version.

CREATE OR REPLACE FUNCTION error_handler_active()

  RETURN true; -- exists(select * from temp_error_stack where fwd_error_ctx = @fwd_error_ctx);

CREATE OR REPLACE FUNCTION initError_B(state BOOLEAN)

  call initError_P(state);

  return true;

CREATE OR REPLACE PROCEDURE initError_P(state BOOLEAN)

DETERMINISTIC

BEGIN

  insert into temp_error_stack(state,fwd_error_ctx) values (state, @fwd_error_ctx);

END;

$$

CREATE OR REPLACE FUNCTION checkError_BB(init BOOLEAN, result BOOLEAN)

   declare top integer;

   declare val boolean;

   set top = (select max(id) from temp_error_stack);

   if top is null then

      return null;

   end if;

   set val = (select state from temp_error_stack where id = top);

   delete from temp_error_stack where id = top;

   return if(val, false, result);

END;

$$

/**

 * Activate error handler

 */

CREATE OR REPLACE PROCEDURE activateErrorHandler()

DETERMINISTIC

begin

   truncate table temp_error_stack;

   set @fwd_error_ctx = uuid();  

END;

$$

/**

 * Reset error handler

 */

CREATE OR REPLACE PROCEDURE resetErrorHandler()

DETERMINISTIC

begin

   truncate table temp_error_stack;

   set @fwd_error_ctx = null;  

END;

$$

# Module   : guard.awk

# Abstract : awk script for generating 'guarded' versions of the MariaDB UDFs

#

# Copyright (c) 2023, Golden Code Development Corporation.

#

# -#- -I- --Date-- --------------------------------Description----------------------------------

# 001 IAS 20230308 Created initial version.

#

# This program is free software: you can redistribute it and/or modify

# it under the terms of the GNU Affero General Public License as

# published by the Free Software Foundation, either version 3 of the

# License, or (at your option) any later version.

#

# This program is distributed in the hope that it will be useful,

# but WITHOUT ANY WARRANTY; without even the implied warranty of

# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

# GNU Affero General Public License for more details.

#

# You may find a copy of the GNU Affero GPL version 3 at the following

# location: https://www.gnu.org/licenses/agpl-3.0.en.html

#

# Additional terms under GNU Affero GPL version 3 section 7:

#

#   Under Section 7 of the GNU Affero GPL version 3, the following additional

#   terms apply to the works covered under the License.  These additional terms

#   are non-permissive additional terms allowed under Section 7 of the GNU

#   Affero GPL version 3 and may not be removed by you.

#

#   0. Attribution Requirement.

#

#     You must preserve all legal notices or author attributions in the covered

#     work or Appropriate Legal Notices displayed by works containing the covered

#     work.  You may not remove from the covered work any author or developer

#     credit already included within the covered work.

#

#   1. No License To Use Trademarks.

#

#     This license does not grant any license or rights to use the trademarks

#     Golden Code, FWD, any Golden Code or FWD logo, or any other trademarks

#     of Golden Code Development Corporation. You are not authorized to use the

#     name Golden Code, FWD, or the names of any author or contributor, for

#     publicity purposes without written authorization.

#

#   2. No Misrepresentation of Affiliation.

#

#     You may not represent yourself as Golden Code Development Corporation or FWD.

#

#     You may not represent yourself for publicity purposes as associated with

#     Golden Code Development Corporation, FWD, or any author or contributor to

#     the covered work, without written authorization.

#

#   3. No Misrepresentation of Source or Origin.

#

#     You may not represent the covered work as solely your work.  All modified

#     versions of the covered work must be marked in a reasonable way to make it

#     clear that the modified work is not originating from Golden Code Development

#     Corporation or FWD.  All modified versions must contain the notices of

#     attribution required in this license.

# Generates 'guarded' versions of the UDFs

# Usage: awk -f guard.awk <udfs.sql >guarded.sql

BEGIN {

print "-- The 'guarded' versions of SQL UDFs";

print "-- Generated automatically from udfs.sql with guard.awk script.";

print "-- DO NOT MODIFY!";

}

/\/\*/, /\*\// {

   print $0;

}

match($0, "^CREATE *OR *REPLACE *FUNCTION *(.*)$", m) {

   f = m[1];

   print "create or replace function guarded_" f; 

}

/^RETURNS/ {

   print tolower($0);

   s = f; 

   gsub(/\(50, 10\)/, "", s); 

   gsub(/\(3\)/, "", s); 

   gsub(/ JSON/, "", s);

   gsub(/ [a-zA-Z]*\)/, ")", s);

   gsub(/ [^,]*, */, ", ", s); 

   gsub(/##!! TODO/, "", s);

   print "deterministic";

   print "begin";

   print "declare tmp text;"

   print "declare exit handler for SQLEXCEPTION";

   print "  begin";

   print "    GET DIAGNOSTICS CONDITION 1 @sqlstate = RETURNED_SQLSTATE,  @errno = MYSQL_ERRNO, @text = MESSAGE_TEXT;";

   print "    set tmp = sformat('ERROR {} ({}): {}', @sqlstate, @errno, @text);";

   print "    if error_handler_active() then";

   print "      call initError_P(true);";

   print "      signal sqlstate '01FWD' set message_text = tmp;";

   print "      return null;";

   print "    else";

   print "      signal sqlstate 'FWD00' set message_text = tmp;";

   print "    end if;";

   print "  end;";

   print "  return " s ";";

   print "end;";

   print "$$";

}

-- The 'guarded' versions of SQL UDFs

-- Generated automatically from udfs.sql with guard.awk script.

-- DO NOT MODIFY!

/*

** Module   : udfs.sql

** Abstract : 'native' versions of the Java UDFs for MariaDB

**

** Copyright (c) 2022, Golden Code Development Corporation.

**

** -#- -I- --Date-- --------------------------------Description----------------------------------

** 001 IAS 20220810 Created UDFs' templates.

*/

/*

** This program is free software: you can redistribute it and/or modify

** it under the terms of the GNU Affero General Public License as

** published by the Free Software Foundation, either version 3 of the

** License, or (at your option) any later version.

**

** This program is distributed in the hope that it will be useful,

** but WITHOUT ANY WARRANTY; without even the implied warranty of

** MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

** GNU Affero General Public License for more details.

**

** You may find a copy of the GNU Affero GPL version 3 at the following

** location: https://www.gnu.org/licenses/agpl-3.0.en.html

**

** Additional terms under GNU Affero GPL version 3 section 7:

**

**   Under Section 7 of the GNU Affero GPL version 3, the following additional

**   terms apply to the works covered under the License.  These additional terms

**   are non-permissive additional terms allowed under Section 7 of the GNU

**   Affero GPL version 3 and may not be removed by you.

**

**   0. Attribution Requirement.

**

**     You must preserve all legal notices or author attributions in the covered

**     work or Appropriate Legal Notices displayed by works containing the covered

**     work.  You may not remove from the covered work any author or developer

**     credit already included within the covered work.

**

**   1. No License To Use Trademarks.

**

**     This license does not grant any license or rights to use the trademarks

**     Golden Code, FWD, any Golden Code or FWD logo, or any other trademarks

**     of Golden Code Development Corporation. You are not authorized to use the

**     name Golden Code, FWD, or the names of any author or contributor, for

**     publicity purposes without written authorization.

**

**   2. No Misrepresentation of Affiliation.

**

**     You may not represent yourself as Golden Code Development Corporation or FWD.

**

**     You may not represent yourself for publicity purposes as associated with

**     Golden Code Development Corporation, FWD, or any author or contributor to

**     the covered work, without written authorization.

**

**   3. No Misrepresentation of Source or Origin.

**

**     You may not represent the covered work as solely your work.  All modified

**     versions of the covered work must be marked in a reasonable way to make it

**     clear that the modified work is not originating from Golden Code Development

**     Corporation or FWD.  All modified versions must contain the notices of

**     attribution required in this license.

*/

/**

 * For debugging.

 * See the commented table definition above 

 */

/**

 * Convert 4GL 'matches' pattern to regex

 */

create or replace function guarded_regex_tb(s TEXT, windows BOOLEAN)

returns text

deterministic

begin

declare tmp text;

declare exit handler for SQLEXCEPTION

  begin

    GET DIAGNOSTICS CONDITION 1 @sqlstate = RETURNED_SQLSTATE,  @errno = MYSQL_ERRNO, @text = MESSAGE_TEXT;

    set tmp = sformat('ERROR {} ({}): {}', @sqlstate, @errno, @text);

    if error_handler_active() then

      call initError_P(true);

      signal sqlstate '01FWD' set message_text = tmp;

      return null;

    else

      signal sqlstate 'FWD00' set message_text = tmp;

    end if;

  end;

  return regex_tb(s, windows);

end;

$$

/**

 * Convert 4GL 'CAN-DO' function pattern to regex

 */

create or replace function guarded_regex_t(s TEXT)

returns text

deterministic

begin

declare tmp text;

declare exit handler for SQLEXCEPTION

  begin

    GET DIAGNOSTICS CONDITION 1 @sqlstate = RETURNED_SQLSTATE,  @errno = MYSQL_ERRNO, @text = MESSAGE_TEXT;

    set tmp = sformat('ERROR {} ({}): {}', @sqlstate, @errno, @text);

    if error_handler_active() then

      call initError_P(true);

      signal sqlstate '01FWD' set message_text = tmp;

      return null;

    else

      signal sqlstate 'FWD00' set message_text = tmp;

    end if;

  end;

  return regex_t(s);

end;

$$

/**

 * Transform the given integer into a string as the time value 

 */

create or replace function guarded_totimestring_lti(v BIGINT, fmt TEXT, tz INTEGER)

returns text

deterministic

begin

declare tmp text;

declare exit handler for SQLEXCEPTION

  begin

    GET DIAGNOSTICS CONDITION 1 @sqlstate = RETURNED_SQLSTATE,  @errno = MYSQL_ERRNO, @text = MESSAGE_TEXT;

    set tmp = sformat('ERROR {} ({}): {}', @sqlstate, @errno, @text);

    if error_handler_active() then

      call initError_P(true);

      signal sqlstate '01FWD' set message_text = tmp;

      return null;

    else

      signal sqlstate 'FWD00' set message_text = tmp;

    end if;

  end;

  return totimestring_lti(v, fmt, tz);

end;

$$

/**

 * Computes a new date by adding respective number of time units.

 * Corresponds to the 4GL ADD-INTERVAL function.

 * 

 * @param   initial

 *          The first date.

 * @param   amount

 *          The count of units to be added.

 * @param   unit

 *          The unit to measure the interval.

 *          

 * @return  The date that is amount units further in time. 

 */

create or replace function guarded_addinterval_dit(initial DATE, amount INTEGER, unit TEXT)

returns date

deterministic

begin

declare tmp text;

declare exit handler for SQLEXCEPTION

  begin

    GET DIAGNOSTICS CONDITION 1 @sqlstate = RETURNED_SQLSTATE,  @errno = MYSQL_ERRNO, @text = MESSAGE_TEXT;

    set tmp = sformat('ERROR {} ({}): {}', @sqlstate, @errno, @text);

    if error_handler_active() then

      call initError_P(true);

      signal sqlstate '01FWD' set message_text = tmp;

      return null;

    else

      signal sqlstate 'FWD00' set message_text = tmp;

    end if;

  end;

  return addinterval_dit(initial, amount, unit);

end;

$$

/**

 * Computes a new date by adding respective number of time units.

 * Corresponds to the 4GL ADD-INTERVAL function.

 * 

 * @param   initial

 *          The first date.

 * @param   amount

 *          The count of units to be added.

 * @param   unit

 *          The unit to measure the interval.

 *          

 * @return  The date that is amount units further in time. 

 */

create or replace function guarded_addinterval_dlt(initial DATE, amount BIGINT, unit TEXT)

returns date

deterministic

begin

declare tmp text;

declare exit handler for SQLEXCEPTION

  begin

    GET DIAGNOSTICS CONDITION 1 @sqlstate = RETURNED_SQLSTATE,  @errno = MYSQL_ERRNO, @text = MESSAGE_TEXT;

    set tmp = sformat('ERROR {} ({}): {}', @sqlstate, @errno, @text);

    if error_handler_active() then

      call initError_P(true);

      signal sqlstate '01FWD' set message_text = tmp;

      return null;

    else

      signal sqlstate 'FWD00' set message_text = tmp;

    end if;

  end;

  return addinterval_dlt(initial, amount, unit);

end;

$$

/**

 * Computes a new date by adding respective number of time units.

 * Corresponds to the 4GL ADD-INTERVAL function.

 * 

 * @param   initial

 *          The first date.

 * @param   amount

 *          The count of units to be added.

 * @param   unit

 *          The unit to measure the interval.

 *          

 * @return  The date that is amount units further in time. 

 */

create or replace function guarded_addinterval_sit(initial TIMESTAMP(3), amount INTEGER, unit TEXT)

returns timestamp(3)

deterministic

begin

declare tmp text;

declare exit handler for SQLEXCEPTION

  begin

    GET DIAGNOSTICS CONDITION 1 @sqlstate = RETURNED_SQLSTATE,  @errno = MYSQL_ERRNO, @text = MESSAGE_TEXT;

    set tmp = sformat('ERROR {} ({}): {}', @sqlstate, @errno, @text);

    if error_handler_active() then

      call initError_P(true);

      signal sqlstate '01FWD' set message_text = tmp;

      return null;

    else

      signal sqlstate 'FWD00' set message_text = tmp;

    end if;

  end;

  return addinterval_sit(initial, amount, unit);

end;

$$

/**

 * Computes a new date by adding respective number of time units.

 * Corresponds to the 4GL ADD-INTERVAL function.

 * 

 * @param   initial

 *          The first date.

 * @param   amount

 *          The count of units to be added.

 * @param   unit

 *          The unit to measure the interval.

 *          

 * @return  The date that is amount units further in time. 

 */

create or replace function guarded_addinterval_slt(initial TIMESTAMP(3), amount BIGINT, unit TEXT)

returns timestamp(3)

deterministic

begin

declare tmp text;

declare exit handler for SQLEXCEPTION

  begin

    GET DIAGNOSTICS CONDITION 1 @sqlstate = RETURNED_SQLSTATE,  @errno = MYSQL_ERRNO, @text = MESSAGE_TEXT;

    set tmp = sformat('ERROR {} ({}): {}', @sqlstate, @errno, @text);

    if error_handler_active() then

      call initError_P(true);

      signal sqlstate '01FWD' set message_text = tmp;

      return null;

    else

      signal sqlstate 'FWD00' set message_text = tmp;

    end if;

  end;

  return addinterval_slt(initial, amount, unit);

end;

$$

/**

 * Test whether one string begins with another case insensitively.

 * Corresponds to the 4GL BEGINS operator

 */

create or replace function guarded_begins_tt(a TEXT, b TEXT)

returns boolean

deterministic

begin

declare tmp text;

declare exit handler for SQLEXCEPTION

  begin

    GET DIAGNOSTICS CONDITION 1 @sqlstate = RETURNED_SQLSTATE,  @errno = MYSQL_ERRNO, @text = MESSAGE_TEXT;

    set tmp = sformat('ERROR {} ({}): {}', @sqlstate, @errno, @text);

    if error_handler_active() then

      call initError_P(true);

      signal sqlstate '01FWD' set message_text = tmp;

      return null;

    else

      signal sqlstate 'FWD00' set message_text = tmp;

    end if;

  end;

  return begins_tt(a, b);

end;

$$

/**

 * Test whether one string begins with another, optionally taking case into account.

 * Corresponds to the 4GL BEGINS operator

 */

create or replace function guarded_begins_ttb(a TEXT, b TEXT, cs BOOLEAN)

returns boolean

deterministic

begin

declare tmp text;

declare exit handler for SQLEXCEPTION

  begin

    GET DIAGNOSTICS CONDITION 1 @sqlstate = RETURNED_SQLSTATE,  @errno = MYSQL_ERRNO, @text = MESSAGE_TEXT;

    set tmp = sformat('ERROR {} ({}): {}', @sqlstate, @errno, @text);

    if error_handler_active() then

      call initError_P(true);

      signal sqlstate '01FWD' set message_text = tmp;

      return null;

    else

      signal sqlstate 'FWD00' set message_text = tmp;

    end if;

  end;

  return begins_ttb(a, b, cs);

end;

$$

/**

 * Returns the uppercase representation of the string.

 * Corresponds to the 4GL CAPS function

 */

create or replace function guarded_caps_t(t TEXT)

returns text

deterministic