如何将java中的反应式JDBC调用转换为scala中的Future？

文章/答案/技术大牛

发布

1回答

scala、jdbc、future、reactive

请看这里的示例：https://github.com/vietj/reactive-pg-client // Pool options PgPoolOptions options = new PgPoolOptions理想情况下，我们可以这样写代码： val f: Future[...] = clientF.query("select ...")

浏览 9提问于2020-01-28得票数 1

回答已采纳

1回答

Scala Play 2.2 Slick 1.0.1 -未来的{ Try {.}超时等待一个可用的连接

scala、playframework-2.0、slick

它解析请求查询字符串并调用方法Schools.findSchoolsByFilter，该方法对表进行scala灵活调用，并根据SchoolFilter对象筛选结果并返回Try[List[School]]我怀疑这可能是某种类似于这个帖子的种族状况。我的问题是，如何更改此代码以安全地异步运行？$1(Future.scala:24) scala.concurrent.impl.Future$PromiseCompletingRunnable

浏览 3提问于2013-12-22得票数 3

回答已采纳

2回答

将Play Framework java承诺转换为Play Framework承诺

java、scala、playframework、promise

我目前正在构建一个Scala框架应用程序，它使用的库返回的结果为F.Promise (Java诺言)。有没有办法将F.Promises ()转换为Scala承诺，还是将包装好的Scala未来从F.Promise中剔除？到目前为止，我看到的唯一方法是获取F.Promise，但这是一个阻塞操作，我希望继续异步工作。第一个答案中描述的方式引导我找到了这段代码。不幸的是

浏览 3提问于2014-10-30得票数 1

回答已采纳

2回答

Spring Boot中的异步控制器

rest、spring-boot、asynchronous

我使用Spring boot创建了Webservice，其中有一个rest控制器，它通过基于供应商的JDBC驱动程序访问数据库并获取记录。在这个过程中，检索到的记录数量超过80K条记录。我已经尝试使用下面的tutorial.But设置异步调用。不幸的是，rest调用仍然超时。

浏览 41提问于2019-05-09得票数 0

2回答

使用Enumerator/Iteratee获取字符串形式的文件文本

scala、stream、playframework-2.0

查看Play Iteratee (响应式处理数据流)，我有一个ArrayByte枚举器(来自文件流)，我需要获得该枚举器的字符串表示(我需要将文本作为流的字符串)Enumerator.fromFileval textString = Await.result(还有其他更简单的解决方案吗

浏览 1提问于2014-08-03得票数 0

3回答

Scala将java.sql.ResultSet转换为Json对象

scala、apache-spark

我使用的是Spark2.3.1，我已经使用从resultSet中检索到了MySQL。resultSet是java.sql.ResultSet的类型。那么如何将ResultSet转换为JSON对象。我不需要使用Spark var connection:Connection = null connection: java.sql.Connection = nullscala> Class.forNa

浏览 22提问于2020-09-04得票数 1

回答已采纳

1回答

如何调用batchWriteItemAsync在scala/spark中加载DynamoDB

scala、apache-spark、amazon-dynamodb

我试图运行batchwriteAsync来将数据加载到Scala(Spark)中，但是在运行时遇到以下错误，请问如何在Scala中正确地处理batchwriteAsync吗？import scala.concurrent.[WriteRequest] = contentSeq.asJava ) batchWriteFuture(t

浏览 3提问于2021-08-04得票数 0

回答已采纳

1回答

通过jdbc传递的sqlite3 integrity_check表示数据库映像格式错误。

scala、jdbc、sqlite、slick

我有一个16 it的sqlite3数据库，可以通过jdbc抛出这个错误： at scala.concurrent.Future$$anonfun$recoverWith$1.apply(Future.scala:346) at scala.concurrent.Future$$anonfun

浏览 4提问于2017-02-02得票数 0

0回答

Slick 3.1.1 sql PSQLException:错误："“+ "”处或附近的语法错误“”

postgresql、scala、slick

我有下面这个简单的(在Postgres中测试过的)查询，它导致了上面的错误，但我找不到它是什么。$$anonfun$recoverWith$1.apply(Future.scala:346) at scala.concurrent.impl

浏览 2提问于2016-12-25得票数 1

回答已采纳

1回答

数据库->雪花: SQL编译错误: Stage：'XYZ‘不能是管道定义中的临时阶段

apache-spark、streaming、databricks、snowflake-cloud-data-platform、azure-databricks

我试图将数据库中的流具体化到雪花表中： parsedStream .writeStream .outputMode(“追加”).options(选项) .option("dbtable“、"test_table我检查了预先创建的阶段和不存在的阶段，这样Databricks就可以创建时间阶段(这就是它应该如何工作的方式)。我得到以下错误：net.snowflake.client.jdbc.SnowflakeSQLException: SQL编译错误:

浏览 3提问于2019-11-07得票数 0

2回答

我在哪里重复我的ResultSet一次太多了？或者它为什么要关闭？

scala、jdbc、playframework、playframework-2.1、anorm

我正在使用anorm访问我的数据库上的数据。DB被写入使用另一个使用Java生成的服务，并使用ebean持久化。每次运行这些查询时，都会获得以下堆栈跟踪的错误：com.mysql.jdbc.SQLError.createSQLException(SQLError.java:927) com.my

浏览 4提问于2013-05-13得票数 3

回答已采纳

4回答

将Java未来转换为Scala未来

scala、future、scala-java-interop

我有一个Java Future对象，我想将它转换成一个Scala Future。val p = Promise() p.success(javaFuture.get) 有更好的方法吗？

浏览 0提问于2016-01-27得票数 26

回答已采纳

1回答

net.snowflake.client.jdbc.SnowflakeSQLException: SQL编译错误:读卡器帐户不支持操作

apache-spark、pyspark、snowflake-cloud-data-platform

我正在尝试从雪花中创建的视图中读取数据，并通过PySpark将数据存储到GCS中。at net.snowflake.client.jdbc.SnowflakeUtil.checkErrorAndThrowExceptionSub(SnowflakeUtil.java:139)at net.snowflake.client.jdbc.SnowflakeUtil.checkErrorAndThrowException(SnowflakeUtil.java:64) atapply(Sn

浏览 3提问于2021-10-14得票数 2

1回答

Azure数据流无法连接到私有云中的托管实例

azure-data-factory、azure-data-flow

(SQLServerException.java:285)\nshaded.msdataflow.com.microsoft.sq我还尝试了以下选项:在设计器中打开数据流，然后在接收器中单击数据流内部的“测试连接”，并获得相同的错误。$$anonfun$connect$2.apply(DataflowJobFuture.scala

浏览 2提问于2021-04-05得票数 0

1回答

如何将数据存储到具有时间戳TIMESTAMP_NTZ的雪花中

apache-spark、pyspark、snowflake-cloud-data-platform、snowflake-schema

请在下面找到相同的代码。Py4JJavaError:调用o2088.save时出错。有关加载选项的更多信息，请在SQL客户机中运行“info loading_data”。(SnowflakeJDBCWrapper.scala:283) at scala.concurrent.impl.Future$PromiseCompletingRunnable.liftedTree1$1(Future.scala:24) at scala

浏览 6提问于2020-07-08得票数 2

1回答

简单巧妙的Scala示例

postgresql、scala、slick

我试图练习一个简单的示例，在Postgres.It中创建一个包含4个文件的表。这是我的DAO.scala文件import slick.lifted.} db.run(deleteByIdQuery(id))这是我的entities.scala_ = println(result)

浏览 1提问于2016-11-04得票数 1

回答已采纳

1回答

Java调用Scala HashMap的getOrElse

java、scala、lambda、java-8

我的java代码看起来像(java8，支持lambda )：... HashMapmap.getOrElse(1, () -> "World");当我构建项目时，它告诉我新的世界，但我的集成开发环境( parameter need Function0<B1>. given int那么，如何在java

浏览 0提问于2016-10-12得票数 2

1回答

从java代码中包装scala* Future中的字符串*

java、scala

我有以下测试方法： return "OK"; //error - should wrap withfuture我怎样才能让它返回一个scala的未来(这是java代码，所以我没有找到任何例子)？

浏览 0提问于2017-03-24得票数 0

1回答

net.snowflake.client.jdbc.SnowflakeSQLException: SQL访问控制错误:不足以对模式“公共”进行操作

apache-spark、pyspark、snowflake-cloud-data-platform、databricks

这是我在数据库中运行的一段代码，用于从雪花中获取数据 SNOWFLAKE_SOURCE_NAME = "net.snowflake.spark.snowflake", query).load() print(df.count())数据和列计数的大小是正确的(Snowflake

浏览 3提问于2021-05-05得票数 1

回答已采纳

1回答

播放框架打开的文件太多

java、spring、hibernate、playframework

我们用的是剧本！使用Java的框架2.3。我们在生产中有一个主要问题，它阻止我们的应用程序运行并向客户端发送数据。 at scala.concurrent.Future$$anonfun$recoverWith$1.apply(Future.scal

浏览 3提问于2016-12-15得票数 0

点击加载更多