import com.softwareag.tamino.db.api.accessor.*;
import com.softwareag.tamino.db.api.connection.*;
import com.softwareag.tamino.db.api.objectModel.*;
import com.softwareag.tamino.db.api.response.*;
import java.io.*;
/**
 *
 * @author  ans
 */
public class TestTaminoByteEncoding {
    
    /** Creates a new instance of Main */
    public TestTaminoByteEncoding() {
    }
    
    /**
     * @param args the command line arguments
     */
    public static void main(String[] args) {
                try {
            
            String contentType = "text/xml; charset=iso-8859-1"; //"application/octed-stream";
            
            System.out.println("saving blob doc");
            
            TConnection conn = TConnectionFactory.getInstance().newConnection("http://<your-server-here>/tamino/<your-database-here>");
            TNonXMLObjectAccessor acc = conn.newNonXMLObjectAccessor(TAccessLocation.newInstance("ino:etc"));
            TNonXMLObject blobBefore = TNonXMLObject.newInstance("d:\\temp\\encodingtest.xml");
            blobBefore.setDoctype("ino:nonXML");
            blobBefore.setDocname("problematic2");
            blobBefore.setContentType(contentType);
            acc.insert(blobBefore);
            
            System.out.println("loading blob doc");
            
            TNonXMLObject blobAfter = acc.retrieve(blobBefore);
            
            System.out.println("writing blob to filesystem");
            System.out.println("blobAfter.getContentType: "+blobAfter.getContentType());
            InputStream in = blobAfter.getInputStream();
            FileOutputStream fos = new FileOutputStream("d:\\temp\\encodingresult.xml");
            byte[] buffer = new byte[10*1024];
            int bytesRead = in.read(buffer);
            while ( bytesRead > 0 ) {
                fos.write(buffer, 0, bytesRead);
                bytesRead = in.read(buffer);
            }                       
            fos.close();
            
            System.out.println("done.");
            
            //System.out.println("PoolStatus:\n"+getPoolStatus());
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    
}