Mailing-List: contact ddlutils-dev-help@db.apache.org; run by ezmlm
Precedence: bulk
Reply-To: ddlutils-dev@db.apache.org
Message-ID: <1294780551.1204538090428.JavaMail.jira@brutus>
Date: Mon, 3 Mar 2008 01:54:50 -0800 (PST)
From: "Rijk van Haaften (JIRA)" <jira@apache.org>
To: ddlutils-dev@db.apache.org
Subject: [jira] Created: (DDLUTILS-197) Implementation for store() and
 exists()
MIME-Version: 1.0
Content-Type: text/plain; charset=utf-8
Content-Transfer-Encoding: 7bit

Implementation for store() and exists()
---------------------------------------

                 Key: DDLUTILS-197
                 URL: https://issues.apache.org/jira/browse/DDLUTILS-197
             Project: DdlUtils
          Issue Type: Improvement
          Components: Core (No specific database)
            Reporter: Rijk van Haaften
            Assignee: Thomas Dudziak
            Priority: Minor


    /**
     * Determines whether the given dyna bean is stored in the database.
     * 
     * @param dynaBean   The bean
     * @param connection The connection
     * @return <code>true</code> if this dyna bean has a primary key
     */
    protected boolean exists(Connection connection, Database model, DynaBean dynaBean)
    {
        SqlDynaClass      dynaClass   = model.getDynaClassFor(dynaBean);
        SqlDynaProperty[] primaryKeys = dynaClass.getPrimaryKeyProperties();
        
        if (primaryKeys.length == 0)
        {
            return false;
        }
        
        String tableName = _builder.getDelimitedIdentifier(dynaClass.getTable().getName());
        StringBuilder sql = new StringBuilder("SELECT * FROM " + tableName + " WHERE ");
        
        for (int i = 0; i < primaryKeys.length; i++)
        {
            if (i > 0)
            {
                sql.append(" AND ");
            }
            String key = primaryKeys[i].getColumn().getName();
            sql.append(_builder.getDelimitedIdentifier(key));
            sql.append('=');
            sql.append('\'');
            sql.append(dynaBean.get(key));
            sql.append('\'');
        }
        
        Statement statement = null;
        ResultSet resultSet = null;
        boolean exists = false;
        try
        {
            statement = connection.createStatement();
            resultSet = statement.executeQuery(sql.toString());
            exists = resultSet.next();
            resultSet.close();
    }
    catch (SQLException ex)
    {
        throw new DatabaseOperationException("Error while reading from the database", ex);
    }
    finally
    {
        closeStatement(statement);
    }
    return exists;
}

    /**
     * {@inheritDoc}
     */
    public void store(Database model, DynaBean dynaBean) throws DatabaseOperationException
    {
        Connection connection = borrowConnection();
        
        try
        {
            if (exists(connection, model, dynaBean))
            {
                update(connection, model, dynaBean);
            }
            else
            {
                insert(connection, model, dynaBean);
            }
        }
        finally
        {
            returnConnection(connection);
        }
    }

-- 
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.