Session Kill

아래 nGQL 로 session 을 확인 / KILL 할 수 있다. 

show SESSIONS;
kill SESSION <sessionId>

 

 

그런데 연결된 session 이 너무 많아 하나씩 KILL 하기 힘들 때는 코드를 작성해 진행할 수 있다.

import com.vesoft.nebula.client.graph.SessionPool
import com.vesoft.nebula.client.graph.data.ResultSet

import scala.collection.JavaConverters._

object KillAllSessions {
	def main(args: Array[String]): Unit = {
		val sessionPool: SessionPool = ...
		val resultSet: ResultSet = sessionPool.execute("SHOW SESSIONS;")

		try {
			val sessionIds: Seq[Long] = for {
				row <- resultSet.getRows.asScala
				id = row.getValues.asScala.head.getIVal
			} yield id

			sessionIds.foreach { id =>
				sessionPool.execute(s"KILL SESSION $id;")
				println(s"Killed session $id")
			}
		} finally {
			sessionPool.close()
		}
	}
}