// This Source Code is in the Public Domain per: http://unlicense.org
package org.litesoft.sql;

import java.util.*;

import org.litesoft.db.*;
import org.litesoft.orsup.base.*;
import org.litesoft.orsup.nonpublic.*;
import org.litesoft.orsup.otherattributeaccessors.*;
import org.litesoft.orsup.selection.*;
import org.litesoft.sql.statements.*;

public class SQLTransactionPersistenceHelper extends SQLORPersistenceHelper implements TransactionPersistenceHelper
{
    public SQLTransactionPersistenceHelper( SQLDBconnectionProvider pSQLDBconnectionProvider )
    {
        super( pSQLDBconnectionProvider );
    }

    @Override
    public void insert( DBconnection pDBconnection, PersistentObjectImpl pPersistentObject, Object pLoggingContext )
            throws DBException
    {
        MetaDataForPO metaDataForPO = pPersistentObject.getMetaDataForPO();
        // Automatically adds the RecordVersion if it exists
        String cmd = "INSERT INTO " + metaDataForPO.getTableName() + //
                     " (" + SQL_OR_Helper.buildAllTableColumns( metaDataForPO ) + ")" + //
                     " VALUES (" + buildInsertValues( metaDataForPO, pPersistentObject ) + ")";

        JDBCexecuteUpdate updater = new JDBCexecuteUpdate( this, pDBconnection, cmd, pLoggingContext );
        try
        {
            updater.executeUpdate( false );
        }
        finally
        {
            updater.dispose();
        }
    }

    @SuppressWarnings({"unchecked"}) @Override
    public void update( DBconnection pDBconnection, PersistentObjectImpl pPersistentObject, Object pLoggingContext )
            throws ConcurrentPOModificationException, DBException
    {
        MetaDataForPO metaDataForPO = pPersistentObject.getMetaDataForPO();
        WhereClause wc = createVersionAwareWhereClause( metaDataForPO, pPersistentObject );
        StringBuilder zUCbuilder = new StringBuilder();

        String zPrefix = "";
        if ( metaDataForPO.isRecordVersionable() )
        {
            String rvName = metaDataForPO.getRecordVersionAttributeName();
            AttributeAccessorSCD_RecordVersion rvAASCD = (AttributeAccessorSCD_RecordVersion) metaDataForPO.getAccessorSCDrequired( rvName );
            Long zNextRecordVersion = rvAASCD.getNextRecordVersion( pPersistentObject );
            zUCbuilder.append( rvAASCD.getColumnName() ).append( '=' );
            WhereClauseColumnSupport.makeSqlValue( zUCbuilder, rvAASCD, false, zNextRecordVersion );
            zPrefix = ", ";
        }

        String updateClause = buildUpdated( zUCbuilder, zPrefix, metaDataForPO, pPersistentObject );
        if ( updateClause.length() == 0 )
        {
            throw new IllegalStateException( "Changes indicated on '" + pPersistentObject + //
                                             "' but did NOT like any of the following attributes: " + //
                                             Arrays.asList( pPersistentObject.getChangedAttributeNames() ) );
        }

        String cmd = createUpdateCmd( metaDataForPO.getTableName(), updateClause, wc.toSQL() );
        int rowsEffected = update( pDBconnection, cmd, false );
        if ( rowsEffected == 0 )
        {
            throw new ConcurrentPOModificationException( cmd, pPersistentObject );
        }
        if ( rowsEffected > 1 )
        {
            throw new MultiRowUpdateException( cmd, rowsEffected );
        }
    }

    @Override
    public void delete( DBconnection pDBconnection, PersistentObjectImpl pPersistentObject, Object pLoggingContext )
            throws ConcurrentPOModificationException, DBException
    {
        MetaDataForPO metaDataForPO = pPersistentObject.getMetaDataForPO();
        WhereClause wc = createVersionAwareWhereClause( metaDataForPO, pPersistentObject );

        String cmd = "DELETE FROM " + metaDataForPO.getTableName() + " " + SQL_OR_Helper.toSQL( true, metaDataForPO, wc );

        JDBCexecuteUpdate updater = new JDBCexecuteUpdate( this, pDBconnection, cmd, pLoggingContext );
        int rows;
        try
        {
            rows = updater.executeUpdate( false );
        }
        finally
        {
            updater.dispose();
        }
        if ( rows == 0 )
        {
            throw new ConcurrentPOModificationException( "Unable to delete", pPersistentObject );
        }
    }

    @SuppressWarnings({"unchecked"})
    private String buildInsertValues( MetaDataForPO pMetaDataForPO, final PersistentObject<?> pPO )
    {
        return SQL_OR_Helper.processPersistingAccessorSCDs( new StringBuilder(), "", pMetaDataForPO, new SQL_OR_Helper.PersistingAccessorSCDprocessor()
        {
            @Override
            public boolean process( StringBuilder pSB, String pPrefix, AttributeAccessorSCD pSCD )
            {
                Object zPOvalue = pSCD.db_getValueOnPO( pPO );

                pSB.append( pPrefix );

                WhereClauseColumnSupport.makeSqlValue( pSB, pSCD, false, zPOvalue );

                if ( pSCD.hasSearchColumn() )
                {
                    pSB.append( ", " );
                    WhereClauseColumnSupport.makeSqlValue( pSB, pSCD, true, zPOvalue );
                }

                return true;
            }
        } );
    }

    @SuppressWarnings({"unchecked"})
    private String buildUpdated( StringBuilder pSB, String pPrefix, MetaDataForPO pMetaDataForPO, final PersistentObject<?> pPO )
    {
        return SQL_OR_Helper.processPersistingAccessorSCDs( pSB, pPrefix, pMetaDataForPO, new SQL_OR_Helper.PersistingAccessorSCDprocessor()
        {
            @Override
            public boolean process( StringBuilder pSB, String pPrefix, AttributeAccessorSCD pSCD )
            {
                if ( !pPO.isAttributeChanged( pSCD ) )
                {
                    return false;
                }
                Object zPOvalue = pSCD.db_getValueOnPO( pPO );

                pSB.append( pPrefix ).append( pSCD.getColumnName() ).append( '=' );

                WhereClauseColumnSupport.makeSqlValue( pSB, pSCD, false, zPOvalue );

                if ( pSCD.hasSearchColumn() )
                {
                    pSB.append( ", " ).append( pSCD.getSearchColumnName() ).append( '=' );
                    WhereClauseColumnSupport.makeSqlValue( pSB, pSCD, true, zPOvalue );
                }

                return true;
            }
        } );
    }
}