Docs Menu
Docs Home
/ / /
Scala
/ /

圧縮

項目一覧

  • ConnectionString を使用した圧縮の指定
  • MongoClientSettings を使用して圧縮を指定する
  • Dependencies

Scala ドライバーは MongoDB サーバーとの間のメッセージの圧縮をサポートしています。 このドライバーは、MongoDB サーバーでサポートされている 3 つのアルゴリズムを実装します。

  • Snappy : バージョン を実行している MongoDB サーバーに接続するときに Snappy3 圧縮を使用できます。4 以降。

  • zlib:zlib MongoDB圧縮は、バージョン3 .6 以降を実行している サーバーに接続するときに使用できます。

  • Zstandard : Zstandard 圧縮は、バージョン を実行している MongoDB4 サーバーに接続するときに使用できます。2 以降。

ドライバーは、 helloコマンド応答でサーバーによって通知される機能に基づいて、どの圧縮アルゴリズムが使用されるかをネゴシエートします。

次のインポート ステートメントを含めます。

import org.mongodb.scala._

ConnectionString 内で圧縮を指定するには、 接続stringの一部としてコンプレッサーを指定します。

次のコードは Snappy 圧縮アルゴリズムを指定します。

val mongoClient: MongoClient = MongoClient("mongodb://localhost/?compressors=snappy")

次のコードはzlib圧縮アルゴリズムを指定します。

val mongoClient: MongoClient = MongoClient("mongodb://localhost/?compressors=zlib")

次のコードは、Zstandard 圧縮アルゴリズムを指定します。

val mongoClient: MongoClient = MongoClient("mongodb://localhost/?compressors=zstd")

次のコードでは、複数の圧縮アルゴリズムを指定します。

val mongoClient: MongoClient = MongoClient("mongodb://localhost/?compressors=snappy,zlib,zstd")

いずれの場合も、ドライバーは、サーバーがサポートしているリスト内の最初のコンプレッサーを使用します。

次のインポート ステートメントを含めます。

import org.mongodb.scala._
import scala.collection.JavaConverters._

MongoClientSettingsインスタンス内で圧縮を指定するには、 compressorsプロパティをMongoCompressorインスタンスのリストに設定します。

次のコードは Snappy 圧縮アルゴリズムを指定します。

val settings = MongoClientSettings.builder()
.compressorList(List(MongoCompressor.createSnappyCompressor).asJava)
.build()
val client = MongoClient(settings)

次のコードはzlib圧縮アルゴリズムを指定します。

val settings = MongoClientSettings.builder()
.compressorList(List(MongoCompressor.createZlibCompressor).asJava)
.build()
val client = MongoClient(settings)

次のコードは、Zstandard 圧縮アルゴリズムを指定します。

val settings = MongoClientSettings.builder()
.compressorList(List(MongoCompressor.createZstdCompressor).asJava)
.build()
val client = MongoClient(settings)

次のコードでは、複数の圧縮アルゴリズムを指定します。

val settings = MongoClientSettings.builder()
.compressorList(List(MongoCompressor.createSnappyCompressor,
MongoCompressor.createZlibCompressor,
MongoCompressor.createZstdCompressor).asJava)
.build()
val client = MongoClient(settings)

接続stringを使用する構成と同様に、ドライバーは、サーバーがサポートしているリスト内の最初のコンプレッサーを使用します。

JDK には Snappy または Zstandard の組み込みサポートがないため、ドライバーは既存のオープンソースの Snappy および Zstandard 実装に依存します。 snappy-javaGithub リポジトリ を参照してください および zstd-javaGithub リポジトリ 詳細については、「 」を参照してください。

戻る

認証