application1.java~27~

javastore 的编程程序

package jdatastorebasic;

import com.borland.datastore.*;

public class Application1 {
    static final String storeFileName="E:/JBuilder2005/samples/JDataStore/datastores/Basic.jds";
    static final String userName="SYSDBA";
    static final String password="masterkey";

    private static void dir() {
        DataStoreConnection store = new DataStoreConnection();
        com.borland.dx.dataset.StorageDataSet storeDir;

        try {
            store.setFileName( storeFileName );
            store.setUserName( userName );
            store.setPassword( password );
            store.open();
            storeDir = store.openDirectory();
            while ( storeDir.inBounds() ) {
                short dirVal = storeDir.getShort( DataStore.DIR_TYPE );
                if ( (dirVal & DataStore.TABLE_STREAM) != 0 ) {
                    System.out.print( "T" );
                } else if ( (dirVal & DataStore.FILE_STREAM) != 0 ) {
                    System.out.print( "F" );
                } else {
                    System.out.print( "?" );
                }
                System.out.print( " " );
                System.out.println( storeDir.getString( DataStore.DIR_STORE_NAME ) );
                storeDir.next();
            }
            store.closeDirectory();
        } catch ( com.borland.dx.dataset.DataSetException dse ) {
            dse.printStackTrace();
        } finally {
            try {
                store.close();
            } catch ( com.borland.dx.dataset.DataSetException dse ) {
                dse.printStackTrace();
            }
        }
    }

    private static void writeString() {
      DataStore  store = new DataStore();

      store.setFileName( storeFileName );
      store.setUserName( userName );
      store.setPassword( password );
      store.open();
      //写入并读取字符串
      try {
          store.writeObject( "String", "Hello, DataStore! It's " + new java.util.Date() );
          String s = (String) store.readObject( "String" );
          System.out.println( s );
      } catch ( com.borland.dx.dataset.DataSetException dse ) {
          dse.printStackTrace();
      } catch ( java.lang.ClassNotFoundException cnfe ) {
          cnfe.printStackTrace();
      } catch ( java.io.IOException ioe ) {
          ioe.printStackTrace();
      }  finally {
              try {
                  store.close();
              } catch ( com.borland.dx.dataset.DataSetException dse ) {
                  dse.printStackTrace();
              }
      }
    }

    private static void writeObjects() {
      DataStoreConnection store = new DataStoreConnection();

      int[]                intArray   = { 5, 7, 9 };
      java.util.Date       date       = new java.util.Date();
      java.util.Properties properties = new java.util.Properties();
      properties.setProperty( "a property", "a value" );

      try {
          store.setFileName( storeFileName );
          store.setUserName( userName );
          store.setPassword( password );
          store.open();
          store.writeObject( "Objects/create-time", date );
          store.writeObject( "Objects/values", properties );
          store.writeObject( "Objects/array of ints", intArray );
      } catch ( com.borland.dx.dataset.DataSetException dse ) {
          dse.printStackTrace();
      } catch ( java.io.IOException ioe ) {
          ioe.printStackTrace();
      } finally {
          try {
              store.close();
          } catch ( com.borland.dx.dataset.DataSetException dse ) {
              dse.printStackTrace();
          }
      }
    }

    private static void writeFile() {
      DataStoreConnection store = new DataStoreConnection();
      String fileToImport="c:/test.txt";

      try {
          store.setFileName( storeFileName );
          store.setUserName( userName );
          store.setPassword( password );
          store.open();

          //写入文件
          FileStream fs = store.createFileStream( fileToImport + "/data" );
          byte[] buffer = new byte[ 4 * store.getDataStore().getBlockSize() * 1024 ];
          java.io.File file = new java.io.File( fileToImport );
          java.io.FileInputStream fis = new java.io.FileInputStream( file );
          int bytesRead;
          while ( (bytesRead = fis.read( buffer )) != -1 ) {
              fs.write( buffer, 0, bytesRead );
          }
          fs.close();
          fis.close();

          //读出文件
          FileStream fs1 = store.createFileStream( fileToImport + "/data" );
          java.io.File file1 = new java.io.File( fileToImport );
          java.io.FileOutputStream fos = new java.io.FileOutputStream( file1 );
          while ( (bytesRead = fs1.read( buffer )) != -1 ) {
              fos.write( buffer, 0, bytesRead );
          }
          fs1.close();
          fos.close();

          store.writeObject( fileToImport + "/modified", new Long( file.lastModified() ) );
      } catch ( com.borland.dx.dataset.DataSetException dse ) {
          dse.printStackTrace();
      } catch ( java.io.FileNotFoundException fnfe ) {
          fnfe.printStackTrace();
      } catch ( java.io.IOException ioe ) {
          ioe.printStackTrace();
      } finally {
          try {
              store.close();
          } catch ( com.borland.dx.dataset.DataSetException dse ) {
              dse.printStackTrace();
          }
        }
    }

    public static void main( String[] args ) {
       dir();
       writeString();
       writeObjects();
       writeFile();
    }

}