Connection with Database at UDJC

[vallim]

Hi guys. I would like to know if the way I'm connecting to database is right. I'm using the step "User Defined Java Class" and init() and dispose() methods. The following code shows how I'm doing:

public boolean init(StepMetaInterface smi, StepDataInterface sdi)
{
    if (parent.initImpl(smi, sdi)){
        try{
            db = new Database(this.parent, getTransMeta().findDatabase("SISPE"));
            db.shareVariablesWith(this.parent);
            db.connect();
            return true;
        }
        catch(KettleDatabaseException e){
            logError("Erro ao conectar no banco SISPE: " + e.getMessage());
            setErrors(1);
            stopAll();
        }
    }
 
    return false;
}
//------------------------- Inicialização dos objetos para conexão com a base de dados -----------//


//------------------------- Fechando conexão com banco de dados ----------------------------------//
public void dispose(StepMetaInterface smi, StepDataInterface sdi)
{
    if (db != null) {
        db.disconnect();
    }
 
    parent.disposeImpl(smi, sdi);

Att. Fabricio Vallim

[MattCasters]

That looks fine to me.

[vallim]

Hi Matt Casters. Thanks for attention. I would like to take other doubt about connection manipulation at Pentaho. In my transformations I'm enabling the "Make transformation database transactional" option for that I can rolling back if occurs an error during the execution of the transformation. My main doubt is about how Pentaho creates and manages your connections. For each "UDJC (User Defined Java Class)" step the Pentaho creates a connection or it creates just one connection for entire transformation?

That looks fine to me.

[MattCasters]

Looking at the source code of the other steps I would say something like this is needed to make the transformation transactional:

if (getTransMeta().isUsingUniqueConnections())
{
synchronized (getTrans()) { db.connect(getTrans().getThreadName(), getPartitionID()); }
}
else
{
db.connect(getPartitionID());
}

[vallim]

Thanks. The problem was resolved.

Att.
Fabricio Vallim