数据库
首页 > 数据库> > mysql-具有CFTRANSACTION的多个数据源

mysql-具有CFTRANSACTION的多个数据源

作者:互联网

我遇到了以下错误:

cftransaction标记内的所有数据库标记的数据源名称必须相同.

这来自以下代码:

transaction action="begin" {
  try {
    var data = {};

    data.time = getTickCount();

    addToLog("Persist", "Started persist operations");

    doClientPersist();
    cleanUp(arguments.importId);

    addToLog("Persist", "Completed the persist operations successfully", ((getTickCount()-data.time)/1000));

    return true;
  } catch (any e) {
    transactionRollback();
    data.error = e;
  }
}

该事务有效地将较低级别方法的分配包装在doClientPersist()中.其中一个这样的调用位于我们的框架数据库抽象层的深处,它从单独的数据源(让我们说“邮政编码”数据源)中提取(选择)经度和纬度信息-此数据源严格是只读的.

<cffunction name="getLatitudeAndLongitude" access="package" returntype="query" output="false">
  <cfargument name="postcode" type="string" required="true" />
  <cfset var qPostcode = ''/>
  <cfquery name="qPostcode" datasource="postcodesDatasource">
    SELECT 
      a.latitude, 
      a.longitude
    FROM 
      postcodes AS a
    WHERE 
      a.postcode = <cfqueryparam cfsqltype="CF_SQL_VARCHAR" value="#postcode#"/>
  </cfquery>
  <cfreturn qPostcode/>
</cffunction>

<cffunction name="getPostcodeCoordinates" access="public" returntype="struct" output="false">
  <cfargument name="postcode" type="string" required="true"/>
  <cfscript>
    var data = {};

    data.postcode = getFormattedPostcode(arguments.postcode);
    data.valid    = isValidPostcode(data.postcode);
    data.coords   = {};

    if (data.valid) {
      data.query = getLatitudeAndLongitude(data.postcode);
      if (isQuery(data.query) && data.query.recordCount) {
        data.coords["latitude"]  = data.query["latitude"][1];
        data.coords["longitude"] = data.query["longitude"][1];
      } else if (data.valid == 2) {
        /** No match, try short postcode (RECURSIVE) **/
        data.coords = getPostcodeCoordinates(trim(left(data.postcode, len(data.postcode)-3)));
      }
    }
    return data.coords;
  </cfscript>
</cffunction>

阅读这个问题,文档说以下内容:

在事务块中,您可以将查询写入多个数据库,但是在将查询写入另一个数据库之前,必须将事务提交或回滚到一个数据库.

不幸的是,如上所述,获取此邮政编码数据的代码与实际的持久操作完全无关,因为它执行的是无法更改的较低层方法的网络,因此我无法在调用之前进行“顶级”事务远程数据源.

无论如何,我可以将“顶层”方法包装在事务中,并且仍然可以调用“邮政编码”数据源-我们不得不为每个客户端复制邮政编码信息是很愚蠢的,但是操作必须如果出现问题,则回滚.

提前致谢.

解决方法:

如我所见,您基本上有两种选择.

1)在交易之外查询您的数据.根据您应用程序的具体情况,这可能是将该方法移至事务处理块之前,拆分该方法,并将其一部分移至事务处理块之前,将数据预取到RAM中(将数据保留为查询内容).变量),然后让您的方法使用此预提取的数据,而不是直接查询数据库.

但是,所有这些解决方案的结果都是相同的.也就是说,SELECT查询本身是在事务之外执行的.

如果出于任何原因都不可行,请继续…

2)使用相同的数据源.请注意,您不必使用相同的数据库,而只需使用相同的数据源.因此,您可以在MySQL中使用database.tablename语法.

通过快速搜索,我找到了一个很好的例子:
Querying multiple databases at once

拥有比我更好的Google-fu的人可能很快就会想到更好的例子.

不过,基础知识是您在查询中使用FROM数据库名称而不是FROM表名称.

我相信这将要求数据库位于同一台MySQL服务器上.

标签:coldfusion-9,coldfusion,transactions,mysql
来源: https://codeday.me/bug/20191031/1974046.html