te')); return $arr; } /* 遍历用户所有主题 * @param $uid 用户ID * @param int $page 页数 * @param int $pagesize 每页记录条数 * @param bool $desc 排序方式 TRUE降序 FALSE升序 * @param string $key 返回的数组用那一列的值作为 key * @param array $col 查询哪些列 */ function thread_tid_find_by_uid($uid, $page = 1, $pagesize = 1000, $desc = TRUE, $key = 'tid', $col = array()) { if (empty($uid)) return array(); $orderby = TRUE == $desc ? -1 : 1; $arr = thread_tid__find($cond = array('uid' => $uid), array('tid' => $orderby), $page, $pagesize, $key, $col); return $arr; } // 遍历栏目下tid 支持数组 $fid = array(1,2,3) function thread_tid_find_by_fid($fid, $page = 1, $pagesize = 1000, $desc = TRUE) { if (empty($fid)) return array(); $orderby = TRUE == $desc ? -1 : 1; $arr = thread_tid__find($cond = array('fid' => $fid), array('tid' => $orderby), $page, $pagesize, 'tid', array('tid', 'verify_date')); return $arr; } function thread_tid_delete($tid) { if (empty($tid)) return FALSE; $r = thread_tid__delete(array('tid' => $tid)); return $r; } function thread_tid_count() { $n = thread_tid__count(); return $n; } // 统计用户主题数 大数量下严谨使用非主键统计 function thread_uid_count($uid) { $n = thread_tid__count(array('uid' => $uid)); return $n; } // 统计栏目主题数 大数量下严谨使用非主键统计 function thread_fid_count($fid) { $n = thread_tid__count(array('fid' => $fid)); return $n; } ?>Multiple database connections are not working in ktor application using exposed library - Stack Overflow
最新消息:雨落星辰是一个专注网站SEO优化、网站SEO诊断、搜索引擎研究、网络营销推广、网站策划运营及站长类的自媒体原创博客

Multiple database connections are not working in ktor application using exposed library - Stack Overflow

programmeradmin3浏览0评论

I’ve two database connections as follows:

val db1 = Database.connect(
    "jdbc:postgresql://localhost:5432/db1",
    driver = ".postgresql.Driver",
    user = "postgres",
    password = "password")

val db2 = Database.connect(
    "jdbc:postgresql://localhost:5432/db2",
    driver = ".postgresql.Driver",
    user = "postgres",
    password = "password"
)

Now if I run the transactions as follows, this does not work as db1 is not being connected.

transaction(db1){
….
}

Instead, if I switch the order in which the above database connections are declared, then it will work.

val db2 = Database.connect(
    "jdbc:postgresql://localhost:5432/db2",
    driver = ".postgresql.Driver",
    user = "postgres",
    password = "password")

val db1 = Database.connect(
    "jdbc:postgresql://localhost:5432/db1",
    driver = ".postgresql.Driver",
    user = "postgres",
    password = "password"
)
transaction(db1){
….
}

Why is it so? My understanding from the exposed documentation is that every time we call the transaction with the database connection object parameter (i.e., db1) the connection gets established. the document even says we can nest different transactions under other transactions. What am I missing in my understanding? Or, is that a matter of some settings/configuration? Can someone please help me? Thanks in advance

One thing you may need to observe here is both connections are to the same Postgres server on the same machine but towards different databases.

发布评论

评论列表(0)

  1. 暂无评论