Database management operations
In this section described database management operation:
You can create db with such signatures
// With database name
influx.createDatabase("db")
res0: Future[Result]
// and with duration
influx.createDatabase("db", Some("2h))
res0: Future[Result]
// and with replication
influx.createDatabase("db", Some("2h"), Some(1))
res0: Future[Result]
// and with shard duration
influx.createDatabase("db", Some("2h"), Some(1), Some("2h"))
res0: Future[Result]
// and with associated retention policy name
influx.createDatabase("db", Some("2h"), Some(1), Some("2h"), Some("my_retention_policy"))
res0: Future[Result]
To choose needed database:
val db: Database = influx.database("mydb")
Drop database
influx.dropDatabase("db_name")
res0: Future[Result]
Drop measurement
influx.dropMeasurement("measurement_name")
res0: Future[Result]
Drop shard bu shardId
influx.dropShard(2)
res0: Future[Result]
Show database measurement
influx.showMeasurement("db_name")
res0: Future[QueryResult[String]]
Show databases:
influx.showDatabase()
res0: Future[QueryResult[String]]
Show measurement tag keys, whereClause
it’s simply predicate to filtering like "bar > 4"
. whereClause
, limit
, offset
are optional parameters.
influx.showTagKeys("database", "measurement", "whereClause", optLimit, optOffset)
res0: Future[QueryResult[String]]
Show measurement tag value’s, whereClause
it’s simply predicate to filtering like "bar > 4"
. whereClause
, limit
, offset
are optional parameters.
influx.showTagValues("db_name", "measuremetn_name", Seq("key1", "key2"), whereClause, limit, offset)
res0: Future[QueryResult[TagValue]]
Show field keys:
influx.showFieldKeys("db_name", "measuremetn_name")
res0: Future[QueryResult[FieldInfo]]