问题标签 [scalikejdbc]

我有以下对 Postgresql 数据库执行的 SQL 代码：

如果我使用update或updateAndRetrieveGeneratedKey在localTx我得到org.postgresql.util.PSQLException: A result was returned when none was expected.. 如果我使用singleinside，readOnly我会得到类似... cannot perform an insert in a read only query. 解决这个问题的正确方法是什么？

I am using Scala 2.12 and have required libraries downloaded via build.sbt.

I have my DB output in below format.

Basically, it is like per valuation date and book, there can be multiple currency data.

I have group by on book (majorly), which will have list of Pnl data based on currency.

Just the rough representation:

Basically. Key will be book and value will be list of pnl data.

I have a case class defined as below:

Basically, my final object is of type BookLevelDaily.

How do I translate the DB output (above) to my BookLevelDaily object?

I can convert the entire result to the list, but further how should I do groupBy?

Firstly above is not of type BookLevelDaily. So how to iterate or group by to separate Pnl level data and map it to key (book).

在implicit val session: DBSession范围内，具体为scalikejdbc.AutoSession：

更新工作

并选择工作

但更新返回列失败，因为事务设置为只读。

org.postgresql.util.PSQLException: ERROR: cannot execute UPDATE in a read-only transaction.

里面的session匹配SQLToResult假设它应该是只读的：

为了避免匹配这种模式，我尝试创建自己DBSession的模式，但放弃了这种方法。我最接近它的工作是：

这失败了，session.connection因为null.

我怎样才能强制它成为 localTx 而不是 readOnly？

我正在使用 ScalikeJDBC 来获取查询结果。但是，问题是输出中的列顺序与我在查询中定义的顺序不符。对我来说，列的顺序非常重要。那么如何解决呢？

我的查询如下所示：

结果中的列顺序如下所示：

我目前正在将数据从数据库迁移到另一个。

为此，我编写了一个 Scala 程序，它同时使用 Slick 和 ScalikeJDBC 从旧数据库中获取数据并分别插入到新数据库中。

我现在面临的问题是，当迁移一批包含大列的行时，longtext程序不断抛出以下错误。

从观察来看，当这种情况发生时，CPU 利用率会上升到几乎 100%。（在整个迁移过程中，利用率徘徊在 80% 左右）

解决此问题的正确方法是什么？

我有一个模型联系人与模型角色的 hasMany 关系。模型角色与具有中间表 RolePhone 的 Phone 具有 hasManyThrough 关系。所有检索动作都设置为急切。

当我检索联系人时，我会看到其角色列表，但每个角色都有一个空的电话列表。但是当我检索所有角色时，他们的电话列表包含正确的电话。

这些关系在联系人和角色中都被标记为默认值，我尝试手动设置角色的 joinDefinitionsenabledEvenIfAssociated = true但这些都不起作用

这些是我的模型，仅显示结构和关系

这是我的数据库结构

这是一个为暴露问题而添加的 Main 类

完整代码位于https://github.com/airabinovich/testing_skinny

我希望检索一个联系人会得到每个角色中的电话列表按照上面的例子，它应该是这样的

但我明白了

我需要从 初始化~/myConfig.json，如下所示：

这意味着我不能打电话scalikejdbc.config.DBs.setupAll()。根据 的值，我如何使用此 JSON 文件从适当的数据库设置中初始化 scalikeJDBC databaseActive？

我使用spark rdd将数据写入mysql，我使用的运算符是foreachPartition，在运算符中我设置连接池并写入数据（使用scalike jdbc的），然后破坏池，但是似乎偶尔找不到连接池，日志说Connection pool is not yet initialized. (name:'xxx)，我不知道为什么会这样

数据终于完全插入了。但是这个异常让我很困惑

你知道为什么这段代码应该在 {implicit session: DBSession => val person1: Person = Person.create(firstname1, lastname1, ssn1, email1, dob1) 中“添加 person s 然后按名字查找”。获取 val person3: Person = Person.create(firstname1, lastname3, ssn3, email3, dob3).get

}

会给出这个错误

? 我不知道为什么这两个onNext电话似乎错过了。

如果不使用 scalikejdbc 的 update 或 execute 函数，我看不到执行我的 sql insert 语句的方法，这两个函数都将我的插入变成了 upsert。

我希望仅当数据库中不存在具有相同 ID 的范围时才插入范围。否则我希望它会抛出一个错误。

实际上，如果范围已经存在，则此代码会对其进行更新。