DataSourceWorkResource

java.lang.Object

com.zfabrik.impl.db.data.DataSourceWorkResource

All Implemented Interfaces:: IWorkResource

public class DataSourceWorkResource extends Object implements IWorkResource

Work resource, keeping the connection per data source on the work unit.

Constructor Summary

Constructors

Constructor

Description

DataSourceWorkResource(DataSourceResource dataSourceResource, Connection conn)
Method Summary

Modifier and Type

Method

Description

void

begin()

void

close()

void

commit()

static String

computeWorkUnitResourceKey(String dataSourceName)

static DataSourceWorkResource

get(DataSourceResource dataSourceResource, ThrowingSupplier<Connection,SQLException> supplier)

Get a work resource from the work unit.

Connection

getConnection()

void

rollback()

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.zfabrik.work.IWorkResource
afterCompletion, beforeCompletion, begin

Constructor Details
- DataSourceWorkResource
  
  public DataSourceWorkResource(DataSourceResource dataSourceResource, Connection conn) throws Exception
  
  Throws:
  
  Exception
Method Details
- get
  
  public static DataSourceWorkResource get(DataSourceResource dataSourceResource, ThrowingSupplier<Connection,SQLException> supplier)
  
  Get a work resource from the work unit. Bind a new one, if none present
- computeWorkUnitResourceKey
  
  public static String computeWorkUnitResourceKey(String dataSourceName)
- getConnection
  
  public Connection getConnection()
- begin
  
  public void begin()
  
  Specified by:
  
  begin in interface IWorkResource
- close
  
  public void close() throws WorkException
  
  Specified by:
  
  close in interface IWorkResource
  
  Throws:
  
  WorkException
- commit
  
  public void commit()
  
  Specified by:
  
  commit in interface IWorkResource
- rollback
  
  public void rollback() throws WorkException
  
  Specified by:
  
  rollback in interface IWorkResource
  
  Throws:
  
  WorkException