Metacat

import java.io.*;

   * This method will register a data file entry in xml_documents and save a

   * data file input Stream into file system..

   *

   * @param  input, the input stream which contain the file content.

   * @param  , the input stream which contain the file content

   * @param docname - the name of DTD, for data file, it is a docid number.

   * @param doctype - "BIN" for data file

   * @param accnum the accession number to use for the INSERT OR UPDATE, which 

   *               includes a revision number for this revision of the document 

   *               (e.g., knb.1.1)

   * @param user the user that owns the document

   * @param serverCode the serverid from xml_replication on which this document

   *        resides.

   */

 public static void writeDataFile(InputStream input, String filePath, 

    String docname, String doctype, String accnum, String user, int serverCode)

                     throws SQLException, AccessionNumberException, Exception

 {

    if (filePath==null||filePath.equals(""))

    {

      throw new 

            Exception("Please specify the directory where file will be store");

    }

    if (accnum==null||accnum.equals(""))

    {

      throw new Exception("Please specify the stored file name");

    }

    //make sure user have file lock grant(local metacat means have it too)

    if (getDataFileLockGrant(accnum, serverCode))

    {

      //register data file into xml_documents table

      registerDocument(docname, doctype, accnum, user, serverCode);

      //write inputstream into file system.

      File dataDirectory = new File(filePath);

      File newFile = new File(dataDirectory, accnum); 

      // create a buffered byte output stream

      // that uses a default-sized output buffer

      FileOutputStream fos = new FileOutputStream(newFile);

      BufferedOutputStream outPut = new BufferedOutputStream(fos);

      BufferedInputStream bis = null;

      bis = new BufferedInputStream(input);

      byte[] buf = new byte[4 * 1024]; // 4K buffer

      int b = bis.read(buf);

      while (b != -1) 

      {

        outPut.write(buf, 0, b);

        b = bis.read(buf);

      }

      bis.close();

	    outPut.close();

	    fos.close();

      //force replication to other server

      MetaCatUtil util = new MetaCatUtil();

      if ((util.getOption("replicationdata")).equals("on"))

      {

        ForceReplicationHandler frh = new 

                               ForceReplicationHandler(accnum, "insert", false);

      }

    }//if

 }

 /**