001 package railo.commons.io.res.type.datasource; 002 003 import java.io.InputStream; 004 import java.sql.SQLException; 005 006 import railo.commons.io.res.type.datasource.core.Core; 007 import railo.runtime.db.DatasourceConnection; 008 009 public class DataWriter extends Thread { 010 011 private Core core; 012 private DatasourceConnection dc; 013 private String prefix; 014 private Attr attr; 015 private InputStream is; 016 private SQLException e; 017 private boolean append; 018 019 private DatasourceResourceProvider drp; 020 021 public DataWriter(Core core, DatasourceConnection dc, String prefix, Attr attr, InputStream is, DatasourceResourceProvider drp, boolean append) { 022 this.core=core; 023 this.dc=dc; 024 this.prefix=prefix; 025 this.attr=attr; 026 this.is=is; 027 this.drp=drp; 028 this.append=append; 029 } 030 031 public void run(){ 032 try { 033 core.write(dc, prefix, attr, is,append); 034 drp.release(dc); 035 //manager.releaseConnection(connId,dc); 036 } 037 catch (SQLException e) { 038 this.e=e; 039 } 040 } 041 042 043 044 public SQLException getException() { 045 return e; 046 } 047 }