Re: Mock Cassandra DB Connection in Unit Testing
One more question, if i have a function which takes RDD as a parameter, how do we mock an RDD ?? On Thu, Oct 29, 2015 at 5:20 PM, Priya Chwrote: > How do we do it for Cassandra..can we use the same Mocking ? > EmbeddedCassandra Server is available with CassandraUnit. Can this be used > in Spark Code as well ? I mean with Scala code ? > > On Thu, Oct 29, 2015 at 5:03 PM, Василец Дмитрий > wrote: > >> there is example how i mock mysql >> import org.scalamock.scalatest.MockFactory >> val connectionMock = mock[java.sql.Connection] >> val statementMock = mock[PreparedStatement] >> (conMock.prepareStatement(_: >> String)).expects(sql.toString).returning(statementMock) >> (statementMock.executeUpdate _).expects() >> >> >> On Thu, Oct 29, 2015 at 12:27 PM, Priya Ch >> wrote: >> >>> Hi All, >>> >>> For my Spark Streaming code, which writes the results to Cassandra >>> DB, I need to write Unit test cases. what are the available test frameworks >>> to mock the connection to Cassandra DB ? >>> >> >> >
Re: Mock Cassandra DB Connection in Unit Testing
How do we do it for Cassandra..can we use the same Mocking ? EmbeddedCassandra Server is available with CassandraUnit. Can this be used in Spark Code as well ? I mean with Scala code ? On Thu, Oct 29, 2015 at 5:03 PM, Василец Дмитрийwrote: > there is example how i mock mysql > import org.scalamock.scalatest.MockFactory > val connectionMock = mock[java.sql.Connection] > val statementMock = mock[PreparedStatement] > (conMock.prepareStatement(_: > String)).expects(sql.toString).returning(statementMock) > (statementMock.executeUpdate _).expects() > > > On Thu, Oct 29, 2015 at 12:27 PM, Priya Ch > wrote: > >> Hi All, >> >> For my Spark Streaming code, which writes the results to Cassandra DB, >> I need to write Unit test cases. what are the available test frameworks to >> mock the connection to Cassandra DB ? >> > >
Mock Cassandra DB Connection in Unit Testing
Hi All, For my Spark Streaming code, which writes the results to Cassandra DB, I need to write Unit test cases. what are the available test frameworks to mock the connection to Cassandra DB ?
Re: Mock Cassandra DB Connection in Unit Testing
there is example how i mock mysql import org.scalamock.scalatest.MockFactory val connectionMock = mock[java.sql.Connection] val statementMock = mock[PreparedStatement] (conMock.prepareStatement(_: String)).expects(sql.toString).returning(statementMock) (statementMock.executeUpdate _).expects() On Thu, Oct 29, 2015 at 12:27 PM, Priya Chwrote: > Hi All, > > For my Spark Streaming code, which writes the results to Cassandra DB, > I need to write Unit test cases. what are the available test frameworks to > mock the connection to Cassandra DB ? >
Re: Mock Cassandra DB Connection in Unit Testing
Does it need to be a mock? Can you use sc.parallelize(data)? From: Priya Ch Date: Thursday, October 29, 2015 at 2:00 PM To: Василец Дмитрий Cc: "user@spark.apache.org<mailto:user@spark.apache.org>", "spark-connector-u...@lists.datastax.com<mailto:spark-connector-u...@lists.datastax.com>" Subject: Re: Mock Cassandra DB Connection in Unit Testing One more question, if i have a function which takes RDD as a parameter, how do we mock an RDD ?? On Thu, Oct 29, 2015 at 5:20 PM, Priya Ch <learnings.chitt...@gmail.com<mailto:learnings.chitt...@gmail.com>> wrote: How do we do it for Cassandra..can we use the same Mocking ? EmbeddedCassandra Server is available with CassandraUnit. Can this be used in Spark Code as well ? I mean with Scala code ? On Thu, Oct 29, 2015 at 5:03 PM, Василец Дмитрий <pronix.serv...@gmail.com<mailto:pronix.serv...@gmail.com>> wrote: there is example how i mock mysql import org.scalamock.scalatest.MockFactory val connectionMock = mock[java.sql.Connection] val statementMock = mock[PreparedStatement] (conMock.prepareStatement(_: String)).expects(sql.toString).returning(statementMock) (statementMock.executeUpdate _).expects() On Thu, Oct 29, 2015 at 12:27 PM, Priya Ch <learnings.chitt...@gmail.com<mailto:learnings.chitt...@gmail.com>> wrote: Hi All, For my Spark Streaming code, which writes the results to Cassandra DB, I need to write Unit test cases. what are the available test frameworks to mock the connection to Cassandra DB ?