ストリームを使用した作業

一般的に使用されるストリーム・メソッドおよびストリーム・プロパティ

一般的に使用されるメソッドには以下のものがあります。

• Read() — ストリームの現在の位置から、指定された数の文字を読み取ります。

• Write() — 現在の位置から、ストリームにデータを追加します。この位置がストリームの末尾に設定されない場合は、既存のデータを上書きします。

• Rewind() — ストリームの先頭に移動します。

• MoveTo() — ストリーム内の特定の位置に移動します。

• MoveToEnd() — ストリームの末尾に移動します。

• CopyFrom() — コピー元のストリームの内容を、このストリームにコピーします。

• NewFileName() — %Stream.FileCharacterOpens in a new tab または %Stream.FileBinaryOpens in a new tab プロパティのファイル名を指定します。

一般的に使用されるプロパティには以下のものがあります。

• AtEnd — Read がデータ・ソースの末尾に到達すると true に設定されます。

• Id — %Location で指定したエクステントの範囲でストリームのインスタンスを特定する一意の識別子。

• Size — ストリームの現在のサイズ (ストリームのタイプに応じて、バイト数または文字数で表されます)。

個々の Stream メソッドおよびプロパティの詳細は、この章の初めに示したクラスの "インターシステムズ・クラス・リファレンス" のエントリを参照してください。

ストリーム・データの読み取りと書き込み

ストリーム・インタフェースの中核は、メソッド Read()、Write()、Rewind() と、プロパティ AtEnd および Size です。

以下の例では、一度に 100 文字ずつ Person.Memo ストリームのデータを読み取り、それをコンソールに書き込みます。len の値は参照によって渡され、毎回 Read の前に 100 にリセットされます。Read メソッドは len で指定された数の文字を読み取ろうとし、次に len を実際に読み取った実際の文字数に設定します。

  Do person.Memo.Rewind()
  While (person.Memo.AtEnd = 0) {
    Set len = 100
    Write person.Memo.Read(.len)
  }

同様に、ストリームにデータを書き込むことができます。

  Do person.Memo.Write("This is some text. ")
  Do person.Memo.Write("This is some more text.")

ストリーム間のデータのコピー

すべてのストリームは CopyFrom() メソッドを含み、1 つのストリームが別のストリームからのデータを取り入れることができます。これを使用して、例えばストリーム・プロパティにファイルのデータをコピーできます。その場合、一方では %Library.FileOpens in a new tab クラスを使用します。これはオペレーティング・システム・コマンドのラッパであり、このクラスを使用することでファイルをストリームとして開くことができます。その場合のコードは以下のようになります。

  // open a text file using a %Library.File stream
  Set file = ##class(%File).%New("\data\textfile.txt")
  Do file.Open("RU") // same flags as the OPEN command

  // Open a Person object containing a Memo stream
  // and copy the file into Memo
  Set person = ##class(Person).%New()
  Do person.Memo.CopyFrom(file)

  Do person.%Save() // save the person object
  Set person = ""   // close the person object
  Set file = ""     // close the file

以下のように、Set コマンドを使用してデータをストリームにコピーすることもできます。

  Set person2.Memo = person1.Memo

ここで、Person クラスの Memo プロパティはストリームの OREF を保持します。このコマンドは person1.Memo の内容を person2.Memo にコピーします。

ストリーム・データの挿入

一時的なストリーム・クラス (データは保存できません) とは別に、ストリームには一時的なストレージ場所と永続的なストレージ場所の両方があります。すべての挿入は一時的な場所に格納され、ストリームを保存する場合にのみ永続的に格納されます。ストリームへの挿入を開始した後でその挿入操作を中止すると、永続的な場所に保存されているデータは変更されません。

ストリームを作成する場合、挿入から開始し、MoveToEnd() を呼び出し、一時的なストリーム・データへの付加を継続します。ただし、ストリームの保存後は、データは永続的なストレージ場所に移動します。その後でこのストリームを再ロードして挿入を開始すると、データは一時的なストレージ領域に挿入され、永続的に格納されているデータには付加されません。

データを付加するこの動作を実行するには、一時的なストリームを作成する必要があります。以下はその例です。

    Set test = ##class(Test).%OpenId(5)
    Set tmpstream = ##class(%Stream.GlobalCharacter).%New()
    Do tmpstream.CopyFrom(test.text)
    Do tmpstream.MoveToEnd()
    Do tmpstream.Write("append text")
    Set test.text = tmpstream
    Set tmpstream = ""
    // Now do whatever you want with the test object

この例では、必要なタイプの一時的なストリームを作成して、Test オブジェクトに格納したストリームからデータをコピーし、新規ストリームの一時的な格納領域にそのデータを配置します。このストリームにデータを追加した後、Test オブジェクトにその OREF を格納し、参照カウントを正確に維持するためにストリームを閉じます。

ストリームでのリテラル値の検索

ストリーム・インタフェースには、FindAt() メソッドが含まれています。このメソッドを使用すると、特定のリテラル値の場所を検索できます。このメソッドには、以下の引数があります。

method FindAt(position As %Integer, target, ByRef tmpstr, caseinsensitive As %Boolean = 0) as %Integer

以下はその説明です。

• position は、検索を開始する位置です。

• target は、検索するリテラル値です。

• tmpstr は参照によって渡され、FindAt() の次回呼び出しに使用できる情報を返します。これは、同じストリームを繰り返し (最後にターゲットが見つかった位置から開始して) 検索するときに使用します。このシナリオでは、position を -1 に指定し、呼び出しのたびに tmpstr を参照で渡します。その後の継続的な FindAt() の呼び出しは、前回の呼び出しの停止位置から開始されます。

• caseinsensitive は、大文字と小文字を区別する検索を実行するかどうかを指定します。既定では、このメソッドは大文字と小文字を区別しません。

このメソッドは、ストリームの先頭から開始したときの、この一致の位置を返します。一致する値が見つからない場合は、-1 を返します。

ストリームの保存

ストリーム・クラスをオブジェクト・プロパティとして使用する場合、ストリーム・データは、格納オブジェクトを保存する際に保存されます。

ストリーム・クラスをスタンドアロン・オブジェクトとして使用する場合、ストリーム・データを保存するには、%Save() メソッドを使用します。(一時的なストリーム・クラス — %Stream.TmpCharacterOpens in a new tab および %Stream.TmpBinaryOpens in a new tab — では、このメソッドは即座に制御を戻し、データを保存しないことに注意してください。)

オブジェクト・アプリケーションでストリームを使用する

ストリーム・プロパティは、そのストリーム・プロパティを所有するオブジェクトによって作成される一時的なオブジェクトを介して操作されます。ストリームは、リテラル値 (ストリームを大きな文字列と見なす) の役割を果たします。2 つのオブジェクト・インスタンスは同じストリームを参照できません。

以下の例では、長いメモが作成されて、コンソールに書き込まれます。

    // create object and stream
    Set p = ##class(Person).%New()
    Set p.Name = "Mo"
    Do p.Memo.Write("This is part one of a long memo")

    // ...

    Do p.Memo.Write("This is part 10000 of a long memo")
    Do p.%Save()
    Set p = ""

    // read object and stream
    Set p = ##class(Person).%Open(oid)
    Do p.Memo.Rewind() // not required first time

    // write contents of stream to console, 100 characters at a time
    While (p.Memo.AtEnd = 0) {
        Set len = 100
        Write p.Memo.Read(.len)
    }
    Set p = ""

埋め込み SQL によるストリームの読み取り

埋め込み SQL を使用して、以下のようにストリームを読むことができます。

1. 埋め込み SQL を使用して、ストリームの ID を選択します。

     &sql(SELECT Memo INTO :memo FROM Person WHERE Person.ID = 12345)
   
   

   

   これはストリームの ID を取得して、memo ホスト変数に代入します。

2. その後、ストリームを開き、通常どおりに処理します。

埋め込み SQL によるストリームの書き出し

埋め込み SQL によってストリームに書き込むには、複数のオプションがあります。挿入する値については、ストリームのオブジェクト参照 (OREF)、ストリームの OREF の文字列バージョン、または文字列リテラルを使用できます。

以下の例で、これらすべての方法を示します。これらの例では、ストリーム値が予期される、Prop1 という名前の列を持つ Test.ClassWStream という名前のテーブルがあるものとします。

以下の例では、オブジェクト参照を使用します。

///use an OREF
ClassMethod Insert1()
{
    set oref=##class(%Stream.GlobalCharacter).%New()
    do oref.Write("Technique 1")

    //do the insert; this time use an actual OREF
    &sql(INSERT INTO Test.ClassWStreams (Prop1) VALUES (:oref))
}

次の例では、オブジェクト参照の文字列バージョンを使用します。

///use a string version of an OREF
ClassMethod Insert2()
{
    set oref=##class(%Stream.GlobalCharacter).%New()
    do oref.Write("Technique 2")

    //next line converts OREF to a string OREF
    set string=oref_""

    //do the insert
    &sql(INSERT INTO Test.ClassWStreams (Prop1) VALUES (:string))
}

最後の例では、文字列リテラルを Prop1 ストリームに挿入します。

///insert a string literal into the stream column
ClassMethod Insert3()
{
    set literal="Technique 3"

    //do the insert; use a string
    &sql(INSERT INTO Test.ClassWStreams (Prop1) VALUES (:literal))
}