// @@@ START COPYRIGHT @@@
//  Licensed to the Apache Software Foundation (ASF) under one
//  or more contributor license agreements. See the NOTICE file
//  distributed with this work for additional information
//  regarding copyright ownership.  The ASF licenses this file
//  to you under the Apache License, Version 2.0 (the
//  "License"); you may not use this file except in compliance
//  with the License.  You may obtain a copy of the License at
// 
//      http://www.apache.org/licenses/LICENSE-2.0
// 
//  Unless required by applicable law or agreed to in writing, software
//  distributed under the License is distributed on an "AS IS" BASIS,
//  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
//  See the License for the specific language governing permissions and
//  limitations under the License.
//  @@@ END COPYRIGHT @@@
// 

// LOB operations can be performed through the Clob interface,
// or the PreparedStatement interface.
// This program shows examples of both interfaces taking a
// variable and putting it into the cat.sch.clobbase table.
//
// The LOB base table for this example is created as:
//    >> CREATE TABLE clobbase
//       ( col1 INT NOT NULL NOT DROPPABLE
//       , col2 CLOB
//       , PRIMARY KEY ( col1 )
//       ) ;
//
// The LOB table for this example is created through
// the T4LobAdmin utility as:
//    >> CREATE TABLE seabase.sch.clobdatatbl
//      ( table_name CHAR(128) NOT NULL NOT DROPPABLE
//      , data_locator LARGEINT NOT NULL NOT DROPPABLE
//      , chunk_no INT NOT NULL NOT DROPPABLE
//      , lob_data VARCHAR(3880)
//      , PRIMARY KEY ( table_name, data_locator, chunk_no )
//      ) ;
//
// ***** The following is the Clob interface...
// - insert the base row with EMPTY_CLOB() as value for
// the LOB column
// - select the LOB column 'for update'
// - load up a byte[] with the data
// - use Outputstream.write(byte[])
//
// ***** The following is the PreparedStatement interface...
// - need an Inputstream object that already has data
// - need a PreparedStatement object that contains the
// 'insert...' DML of the base table
// - ps.setAsciiStream() for the lob data
// - ps.executeupdate(); for the DML
//
// To run this example, issue the following:
// # java TestCLOB 1 TestCLOB.java 1000
//
import java.sql.* ;
import java.io.* ;

public class TestCLOB
{ public static void main ( String[] args )
  throws java.io.FileNotFoundException, java.io.IOException
  {
     int length = 500 ;
     int recKey ;
     long start ;
     long end ;
     Connection conn1 = null ;

     // Set t4jdbc.clobTableName System Property. This property
     // can also be added to the command line through
     // "-Dt4jdbc.clobTableName=...", or a
     // java.util.Properties object can be used and passed to
     // getConnection.
     System.setProperty( "t4jdbc.clobTableName"
                       , "Seabase.sch.clobdatatbl"
		       ) ;

     if ( args.length < 2 )
     {
        System.out.println( "arg[0]=; arg[1]=file; arg[2]=") ;
	return;
     }

     String k = "K" ;
     for ( int i=0 ; i<5000 ; i++ ) k = k + "K" ;
     System.out.println( "string length = " + k.length() ) ;

     FileInputStream clobFs = new FileInputStream( args[1] ) ;
     int clobFsLen = clobFs.available() ;

     if ( args.length == 3 )
        length = Integer.parseInt( args[2] ) ;
     recKey = Integer.parseInt( args[0] ) ;
     System.out.println( "Key: "
                       + recKey
		       + "; Using "
		       + length
		       + " of file "
		       + args[ 1 ]
		       ) ;

     try
     {
       Class.forName( "org.trafodion.jdbc.t4.T4Driver" ) ;
       start = System.currentTimeMillis() ;

       // url should be of the form:
       // jdbc:t4jdbc://ip_address|host_name:37800/:"
       // where host_name is the database host name
       String url= "jdbc:t4jdbc://host_name:37800/:" ;
       conn1 = DriverManager.getConnection( url ) ;
	
       System.out.println( "Cleaning up test tables..." ) ;
       Statement stmt0 = conn1.createStatement() ;
       stmt0.execute( "DELETE FROM clobdatatbl" ) ;
       stmt0.execute( "DELETE FROM clobbase" ) ;
       conn1.setAutoCommit( false ) ;
     }
     catch (Exception e1)
     {
       e1.printStackTrace() ;
     }

     // PreparedStatement interface example - This technique
     // is suitable if the LOB data is already on disk.
     try
     {
       System.out.println("PreparedStatement interface LOB insert...") ;
       String stmtSource1 = "INSERT INTO clobbase VALUES (?,?) " ;

       PreparedStatement stmt1 = conn1.prepareStatement( stmtSource1 ) ;
       stmt1.setInt( 1, recKey ) ;
       stmt1.setAsciiStream( 2, clobFs, length ) ;
       stmt1.executeUpdate() ;
       conn1.commit() ;
    } 
    catch (SQLException e)
    {
       e.printStackTrace() ;
       SQLException next = e ;
       do
       {
          System.out.println( "Message : " + e.getMessage() ) ;
          System.out.println( "Error Code : " + e.getErrorCode() ) ;
          System.out.println( "SQLState : " + e.getSQLState() ) ;
       }
       while ( ( next = next.getNextException() ) != null ) ;
    }

    // Clob interface example - This technique is suitable when
    // the LOB data is already in the app, such as having been
    // transferred in a msgbuf.
    try
    {
      // insert a second base table row with an empty LOB column
      System.out.println( "CLOB interface EMPTY LOB insert..." ) ;
      String stmtSource2 = "INSERT INTO clobbase VALUES ( ?, EMPTY_CLOB() ) " ;

      PreparedStatement stmt2 = conn1.prepareStatement( stmtSource2 ) ;
      stmt2.setInt( 1, recKey+1 ) ;
      stmt2.executeUpdate() ;

      Clob clob = null ;
      System.out.println( "Obtaining CLOB data to update (EMPTY in this case)..." ) ;

      PreparedStatement stmt3 =
         conn1.prepareStatement( "SELECT col2 FROM clobbase WHERE col1 = ? FOR UPDATE" ) ;
      stmt3.setInt( 1, recKey+1 ) ;
      ResultSet rs = stmt3.executeQuery() ;

      if ( rs.next() )
         // has to be there else the base table insert fails
         clob = rs.getClob( 1 ) ; 

      System.out.println( "Writing data to previously empty CLOB..." ) ;
      OutputStream os = clob.setAsciiStream( 1 ) ;
      byte[] bData = k.getBytes() ;
      os.write(bData) ;
      os.close() ;
      conn1.commit() ;
    }
    catch (SQLException e)
    {
       e.printStackTrace() ;
       SQLException next = e ;

       do
       {
          System.out.println( "Message : " + e.getMessage() ) ;
          System.out.println( "Vendor Code : " + e.getErrorCode() ) ;
          System.out.println( "SQLState : " + e.getSQLState() ) ;
       }
       while ( ( next = next.getNextException() ) != null ) ;
    }
  } // main
} // class