poststats/golf-rs-api
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

using DS release to close

Browse Source
This commit is contained in:
Brian Long 2023-06-14 11:57:11 -04:00
parent ffaea04b86
commit 03fa19734b
2 changed files with 3 additions and 15 deletions
src/main/java/com/poststats/golf/provider/impl
DefaultConnectionProvider.javaTxConnectionProvider.java

8
src/main/java/com/poststats/golf/provider/impl/DefaultConnectionProvider.java

@ -4,13 +4,11 @@ import com.poststats.golf.provider.GolfProvider;
import com.poststats.provider.ConnectionProvider;
import com.poststats.provider.DataSourceProvider;
import com.poststats.provider.NonTransactionalProvider;
import com.poststats.service.ServiceException;
import jakarta.annotation.PostConstruct;
import jakarta.annotation.PreDestroy;
import jakarta.enterprise.context.ApplicationScoped;
import jakarta.inject.Inject;
import java.sql.Connection;
import java.sql.SQLException;
@ApplicationScoped
@NonTransactionalProvider
@ -30,11 +28,7 @@ public class DefaultConnectionProvider implements ConnectionProvider {
@PreDestroy
public void release() {
try {
this.dbcon.close();
} catch (SQLException se) {
throw new ServiceException(se);
}
this.dsp.get().release(this.dbcon);
}
@Override

10
src/main/java/com/poststats/golf/provider/impl/TxConnectionProvider.java

@ -4,14 +4,12 @@ import com.poststats.golf.provider.GolfProvider;
import com.poststats.provider.ConnectionProvider;
import com.poststats.provider.DataSourceProvider;
import com.poststats.provider.TransactionalProvider;
import com.poststats.service.ServiceException;
import jakarta.annotation.PostConstruct;
import jakarta.annotation.PreDestroy;
import jakarta.inject.Inject;
import jakarta.transaction.TransactionScoped;
import java.io.Serializable;
import java.sql.Connection;
import java.sql.SQLException;
@TransactionScoped
@TransactionalProvider
@ -26,16 +24,12 @@ public class TxConnectionProvider implements ConnectionProvider, Serializable {
@PostConstruct
public void acquire() {
this.dbcon = this.dsp.get().acquire(true);
this.dbcon = this.dsp.get().acquireTX(true);
}
@PreDestroy
public void release() {
try {
this.dbcon.close();
} catch (SQLException se) {
throw new ServiceException(se);
}
this.dsp.get().releaseTX(this.dbcon);
}
@Override