This is a Scala client for Amazon CloudSearch.
Add a following dependency into your build.sbt at first.
libraryDependencies += "jp.co.bizreach" %% "aws-cloudsearch-scala" % "0.0.2"Then you can use aws-cloudsearch-scala in your code.
import jp.co.bizreach.cloudsearch4s.CloudSearch
import jp.co.bizreach.cloudsearch4s.CloudSearch._
val cloudsearch = CloudSearch(CloudSearchSettings(
registerUrl = "http://xxxx",
searchUrl = "http://xxxx"
))cloudsearch4s can handle documents as Map[String, Any] or case class. If you want to handle documents as case class, you have to define a case class which is mapped to the index in the CloudSearch at first.
If you use case class, camel case property names are mapped to lowercase with underscore.
case class Job(
jobTitle: String, // mapped to job_title
jobContent: String, // mapped to job_content
salary: Int // mapped to salary
)// Register single document by Map
cloudsearch.registerIndexByMap(
Map("job_title" -> "Title", "job_content" -> "Content")
) match {
case Left(error) => println(error.messages) // CloudSearchError
case Right(id) => println(id) // String
}
// Register multiple documents by Map
cloudsearch.registerIndicesByMap(Seq(
Map("job_title" -> "Title", "job_content" -> "Content"),
Map("job_title" -> "Title", "job_content" -> "Content")
)) match {
case Left(error) => println(error.messages) // CloudSearchError
case Right(ids) => println(ids) // Seq[String]
}
// Register single document by case class
cloudsearch.registerIndex(Job("Title", "Content")) match {
case Left(error) => println(error.messages) // CloudSearchError
case Right(id) => println(id) // String
}
// Register multiple documents by case class
cloudsearch.registerIndices(Seq(
Job(Title, Content), Job(Title, Content)
)) match {
case Left(error) => println(error.messages) // CloudSearchError
case Right(ids) => println(ids) // Seq[String]
}// Update single document by Map
cloudsearch.updateIndexByMap(
"091f2b7e-5b3b-4936-ae42-c560655a165f",
Map("job_title" -> "Title", "job_content" -> "Content")
) match {
case Left(error) => println(error.messages) // CloudSearchError
case Right(id) => println(id) // String
}
// Update multiple documents by case class
cloudsearch.updateIndices(Seq(
("091f2b7e-5b3b-4936-ae42-c560655a165f", Job("Title", "Content")),
("00dd1a55-0e6d-437a-9e16-8f8b50f45a20", Job("Title", "Content"))
)) match {
case Left(error) => println(error.messages) // CloudSearchError
case Right(ids) => println(ids) // Seq[String]
}// Delete single document
cloudsearch.removeIndex("091f2b7e-5b3b-4936-ae42-c560655a165f") match {
case Left(error) => println(error.messages) // CloudSearchError
case Right(id) => println(id) // String
}
// Delete multiple documents
cloudsearch.removeIndices(Seq(
"091f2b7e-5b3b-4936-ae42-c560655a165f",
"00dd1a55-0e6d-437a-9e16-8f8b50f45a20"
)) match {
case Left(error) => println(error.messages) // CloudSearchError
case Right(ids) => println(ids) // Seq[String]
}cloudsearch.search(classOf[Job],
// Query which is assembled using Lucene's query builder API
new TermQuery(new Term("index_type", "crawl"))
// Highlight settings (Optional)
highlights = Seq(HighlightParam("job_title")),
// Facet search settings (Optional)
facets = Seq(FacetParam("employment_status"))
) match {
case Left(error) => println(error.messages) // CloudSearchError
case Right(result) => { // CloudSearchResult[Job]
...
}
}To mock CloudSearch, use CloudSearchMock instead of an instance which is generated by the companion object.
val testService = new HogeService {
override protected val cloudsearch = new CloudSearchMock(Map(
"q=*:*" -> CloudSearchResult[Job](
total = 1,
hits = Seq(
CloudSearchDocument(
id = "091f2b7e-5b3b-4936-ae42-c560655a165f",
fields = Job("Title", "Content"),
highlight = Map.empty
)
),
facets = Map.empty
)
))
...
}Give expected queries and its result to the constructor of CloudSearchMock. If unspecified query is given, test is failed.
And it's possible to get history of request by CloudSearchMock#executedRequests. You can check whether expected requests are sent.
