{}
#+ DB schema - Data Management (mydatabase)
--------------------------------------------------------------------------------
--This code is generated with the template dbapp5.0
--Warning: Enter your changes within a or section, otherwise they will be lost.
{} {}
--------------------------------------------------------------------------------
--Importing modules
IMPORT FGL libdbappCore
IMPORT FGL libdbappSql
IMPORT FGL mydatabase
IMPORT FGL mydatabase_events
IMPORT FGL mydatabase_dbxconstraints
{} {}
--------------------------------------------------------------------------------
--Database schema
SCHEMA mydatabase
--------------------------------------------------------------------------------
--Functions
{}
#+ Select a row identified by the primary key in the "seqreg" table
#+
#+ @param p_key - Primary Key
#+ @param p_lock - Indicate if a lock is used in order to prevent several users editing the same rows at the same time
#+
#+ @returnType INTEGER, LIKE seqreg.*
#+ @return ERROR_SUCCESS|ERROR_FAILURE|ERROR_NOTFOUND, RECORD LIKE seqreg.*
PUBLIC FUNCTION mydatabase_dbxdata_seqreg_pk_seqreg_selectRowByKey(p_key, p_lock)
DEFINE p_key
RECORD
seqreg_sr_name LIKE seqreg.sr_name
END RECORD
DEFINE p_lock BOOLEAN
DEFINE l_data RECORD LIKE seqreg.*
DEFINE l_supportLock BOOLEAN
DEFINE errNo INTEGER
{} {}
LET errNo = ERROR_SUCCESS
-- SQLite does not support the FOR UPDATE close in SELECT syntax
LET l_supportLock = (UPSHIFT(fgl_db_driver_type()) != "SQT")
{} {}
TRY
IF p_lock AND l_supportLock THEN
SELECT * INTO l_data.* FROM seqreg
WHERE @seqreg.sr_name = p_key.seqreg_sr_name
FOR UPDATE
ELSE
SELECT * INTO l_data.* FROM seqreg
WHERE @seqreg.sr_name = p_key.seqreg_sr_name
END IF
IF SQLCA.SQLCODE == NOTFOUND THEN
LET errNo = ERROR_NOTFOUND
END IF
CATCH
INITIALIZE l_data.* TO NULL
LET errNo = ERROR_FAILURE
END TRY
{} {}
RETURN errNo, l_data.*
END FUNCTION
{} --fct.seqreg_pk_seqreg_selectRowByKey
{}
#+ Insert a row in the "seqreg" table and return the primary key created
#+
#+ @param p_data - a row data LIKE seqreg.*
#+
#+ @returnType INTEGER, STRING, VARCHAR(30)
#+ @return ERROR_SUCCESS|ERROR_FAILURE, error message, seqreg.sr_name
PRIVATE FUNCTION mydatabase_dbxdata_seqreg_insertRowByKey(p_data)
DEFINE p_data RECORD LIKE seqreg.*
DEFINE errNo INTEGER
DEFINE errMsg STRING
{} {}
LET errNo = libdbapp_begin_work()
IF errNo == ERROR_SUCCESS THEN
{} {}
IF mydatabase_events.m_DbxDataEvent_seqreg_BeforeInsertRowByKey IS NOT NULL THEN
CALL mydatabase_events.m_DbxDataEvent_seqreg_BeforeInsertRowByKey(p_data.*)
RETURNING errNo, errMsg, p_data.*
END IF
IF errNo == ERROR_SUCCESS THEN
CALL mydatabase_dbxconstraints.mydatabase_dbxconstraints_seqreg_checkTableConstraints(FALSE, p_data.*) RETURNING errNo, errMsg
END IF
{} {}
IF errNo == ERROR_SUCCESS THEN
TRY
INSERT INTO seqreg VALUES (p_data.*)
CATCH
LET errNo = ERROR_FAILURE
END TRY
IF mydatabase_events.m_DbxDataEvent_seqreg_AfterInsertRowByKey IS NOT NULL THEN
CALL mydatabase_events.m_DbxDataEvent_seqreg_AfterInsertRowByKey(p_data.*)
RETURNING errNo, errMsg
END IF
{} {}
END IF
IF errNo == ERROR_SUCCESS THEN
LET errNo = libdbapp_commit_work()
ELSE
CALL libdbapp_rollback_work()
END IF
END IF
RETURN errNo, errMsg, p_data.sr_name
END FUNCTION
{} --fct.seqreg_insertRowByKey
{}
#+ Insert a row in the "seqreg" table and return the table keys
#+
#+ @param p_data - a row data LIKE seqreg.*
#+
#+ @returnType INTEGER, STRING, VARCHAR(30)
#+ @return ERROR_SUCCESS|ERROR_FAILURE, error message, seqreg.sr_name
PUBLIC FUNCTION mydatabase_dbxdata_seqreg_pk_seqreg_insertRowByKey(p_data)
DEFINE p_data RECORD LIKE seqreg.*
DEFINE errNo INTEGER
DEFINE errMsg STRING
{} {}
{} {}
CALL mydatabase_dbxdata_seqreg_insertRowByKey(p_data.*) RETURNING errNo, errMsg, p_data.sr_name
RETURN errNo, errMsg, p_data.sr_name
END FUNCTION
{} --fct.seqreg_pk_seqreg_insertRowByKey
{}
#+ Update a row identified by the primary key in the "seqreg" table
#+
#+ @param p_dataT0 - a row data LIKE seqreg.*
#+ @param p_dataT1 - a row data LIKE seqreg.*
#+
#+ @returnType INTEGER, STRING
#+ @return ERROR_SUCCESS|ERROR_FAILURE|ERROR_CONCURRENT_ACCESS_NOTFOUND|ERROR_CONCURRENT_ACCESS_FAILURE, error message
PUBLIC FUNCTION mydatabase_dbxdata_seqreg_pk_seqreg_updateRowByKey(p_dataT0, p_dataT1)
DEFINE p_dataT0 RECORD LIKE seqreg.*
DEFINE p_dataT1 RECORD LIKE seqreg.*
DEFINE l_key
RECORD
seqreg_sr_name LIKE seqreg.sr_name
END RECORD
DEFINE errNo INTEGER
DEFINE errMsg STRING
{} {}
LET l_key.seqreg_sr_name = p_dataT0.sr_name
INITIALIZE errMsg TO NULL
LET errNo = libdbapp_begin_work()
IF errNo == ERROR_SUCCESS THEN
{} {}
TRY
LET errNo = mydatabase_dbxdata_seqreg_pk_seqreg_checkRowByKeyWithConcurrentAccess(p_dataT0.*, TRUE)
{} {}
IF errNo == ERROR_SUCCESS THEN
CALL mydatabase_dbxconstraints.mydatabase_dbxconstraints_seqreg_checkTableConstraints(TRUE, p_dataT1.*) RETURNING errNo, errMsg
{} {}
IF errNo == ERROR_SUCCESS THEN
IF mydatabase_events.m_DbxDataEvent_seqreg_BeforeUpdateRowByKey IS NOT NULL THEN
CALL mydatabase_events.m_DbxDataEvent_seqreg_BeforeUpdateRowByKey(p_dataT1.*)
RETURNING errNo, errMsg
END IF
UPDATE seqreg
SET seqreg.* = p_dataT1.*
WHERE @seqreg.sr_name = l_key.seqreg_sr_name
END IF
END IF
CATCH
LET errNo = ERROR_FAILURE
END TRY
IF mydatabase_events.m_DbxDataEvent_seqreg_AfterUpdateRowByKey IS NOT NULL THEN
CALL mydatabase_events.m_DbxDataEvent_seqreg_AfterUpdateRowByKey(p_dataT1.*)
RETURNING errNo, errMsg
END IF
{} {}
IF errNo == ERROR_SUCCESS THEN
LET errNo = libdbapp_commit_work()
ELSE
CALL libdbapp_rollback_work()
END IF
END IF
RETURN errNo, errMsg
END FUNCTION
{} --fct.seqreg_pk_seqreg_updateRowByKey
{}
#+ Delete a row identified by the primary key in the "seqreg" table
#+
#+ @param p_key - Primary Key
#+
#+ @returnType INTEGER
#+ @return ERROR_SUCCESS|ERROR_FAILURE|ERROR_DELETE_CASCADE_ROW_USED
PUBLIC FUNCTION mydatabase_dbxdata_seqreg_pk_seqreg_deleteRowByKey(p_key)
DEFINE p_key
RECORD
seqreg_sr_name LIKE seqreg.sr_name
END RECORD
DEFINE errNo INTEGER
{} {}
LET errNo = libdbapp_begin_work()
IF errNo == ERROR_SUCCESS THEN
{} {}
IF mydatabase_events.m_DbxDataEvent_seqreg_BeforeDeleteRowByKey IS NOT NULL THEN
CALL mydatabase_events.m_DbxDataEvent_seqreg_BeforeDeleteRowByKey(p_key.*)
RETURNING errNo
END IF
TRY
DELETE FROM seqreg
WHERE @seqreg.sr_name = p_key.seqreg_sr_name
CATCH
LET errNo = ERROR_FAILURE
END TRY
IF mydatabase_events.m_DbxDataEvent_seqreg_AfterDeleteRowByKey IS NOT NULL THEN
CALL mydatabase_events.m_DbxDataEvent_seqreg_AfterDeleteRowByKey(p_key.*)
RETURNING errNo
END IF
{} {}
IF errNo == ERROR_SUCCESS THEN
LET errNo = libdbapp_commit_work()
ELSE
CALL libdbapp_rollback_work()
END IF
END IF
RETURN errNo
END FUNCTION
{} --fct.seqreg_pk_seqreg_deleteRowByKey
{}
#+ Delete a row identified by the primary key in the "seqreg" table if the concurrent access is success
#+
#+ @param p_dataT0 - a row data LIKE seqreg.*
#+
#+ @returnType INTEGER
#+ @return ERROR_SUCCESS|ERROR_FAILURE|ERROR_CONCURRENT_ACCESS_NOTFOUND|ERROR_CONCURRENT_ACCESS_FAILURE|ERROR_DELETE_CASCADE_ROW_USED
PUBLIC FUNCTION mydatabase_dbxdata_seqreg_pk_seqreg_deleteRowByKeyWithConcurrentAccess(p_dataT0)
DEFINE p_dataT0 RECORD LIKE seqreg.*
DEFINE l_key
RECORD
seqreg_sr_name LIKE seqreg.sr_name
END RECORD
DEFINE errNo INTEGER
{} {}
LET l_key.seqreg_sr_name = p_dataT0.sr_name
LET errNo = libdbapp_begin_work()
IF errNo == ERROR_SUCCESS THEN
{} {}
LET errNo = mydatabase_dbxdata_seqreg_pk_seqreg_checkRowByKeyWithConcurrentAccess(p_dataT0.*, TRUE)
{} {}
IF errNo == ERROR_SUCCESS THEN
LET errNo = mydatabase_dbxdata_seqreg_pk_seqreg_deleteRowByKey(l_key.*)
END IF
{} {}
IF errNo == ERROR_SUCCESS THEN
LET errNo = libdbapp_commit_work()
ELSE
CALL libdbapp_rollback_work()
END IF
END IF
RETURN errNo
END FUNCTION
{} --fct.seqreg_pk_seqreg_deleteRowByKeyWithConcurrentAccess
{}
#+ Check if a row identified by the primary key in the "seqreg" table has been modified or deleted
#+
#+ @param p_dataT0 - a row data LIKE seqreg.*
#+ @param p_lock - Indicate if a lock is used in order to prevent several users editing the same rows at the same time
#+
#+ @returnType INTEGER
#+ @return ERROR_SUCCESS|ERROR_FAILURE|ERROR_CONCURRENT_ACCESS_NOTFOUND|ERROR_CONCURRENT_ACCESS_FAILURE
PUBLIC FUNCTION mydatabase_dbxdata_seqreg_pk_seqreg_checkRowByKeyWithConcurrentAccess(p_dataT0, p_lock)
DEFINE p_dataT0 RECORD LIKE seqreg.*
DEFINE l_dataT2 RECORD LIKE seqreg.*
DEFINE l_key
RECORD
seqreg_sr_name LIKE seqreg.sr_name
END RECORD
DEFINE p_lock BOOLEAN
DEFINE errNo INTEGER
DEFINE errDiff INTEGER
{} {}
LET l_key.seqreg_sr_name = p_dataT0.sr_name
INITIALIZE l_dataT2.* TO NULL
LET errDiff = FALSE
{} {}
CALL mydatabase_dbxdata_seqreg_pk_seqreg_selectRowByKey(l_key.*, p_lock) RETURNING errNo, l_dataT2.*
CASE errNo
WHEN ERROR_SUCCESS
LET errDiff = (p_dataT0.* != l_dataT2.*)
{} {}
IF NOT errDiff THEN
LET errNo = ERROR_SUCCESS
ELSE
LET errNo = ERROR_CONCURRENT_ACCESS_FAILURE
END IF
WHEN ERROR_NOTFOUND
LET errNo = ERROR_CONCURRENT_ACCESS_NOTFOUND
END CASE
{} {}
RETURN errNo
END FUNCTION
{} --fct.seqreg_pk_seqreg_checkRowByKeyWithConcurrentAccess
{}
#+ Set data with the default values coming from the DB schema
#+
PUBLIC FUNCTION mydatabase_dbxdata_seqreg_setDefaultValuesFromDBSchema()
DEFINE l_data RECORD LIKE seqreg.*
{} {}
INITIALIZE l_data.* TO NULL
{} {}
IF mydatabase_events.m_DbxDataEvent_seqreg_SetDefaultValues IS NOT NULL THEN
CALL mydatabase_events.m_DbxDataEvent_seqreg_SetDefaultValues(l_data.*)
RETURNING l_data.*
END IF
RETURN l_data.*
END FUNCTION
{} --fct.seqreg_setDefaultValuesFromDBSchema
--------------------------------------------------------------------------------
--Add user functions
{} {}