主要内容

createConnectionForPool

使用数据库连接初始化并行池

描述

例子

c= createConnectionForPool (数据源用户名密码通过使用数据源、用户名和密码在池中的每个worker上创建数据库连接来初始化并行池。

请注意

如果使用ODBC数据源进行数据库连接,池中的每个worker都必须安装所需的ODBC驱动程序和配置的ODBC数据源。否则,从数据库导入数据时会出现错误。

例子

全部折叠

使用ODBC数据库连接,使用并行池访问数据库(需要并行计算工具箱™)。从多个SQL查询中并行导入数据。

池中的每个worker都安装了ODBC驱动程序。此外,每个工作人员都有一个配置好的ODBC数据源。有关更多信息,请参见configureODBCDataSource函数。

启动并行池。

Pool = gcp;
使用“本地”配置文件启动并行池(parpool)…连接到并行池(工人数:6)。

使用ODBC数据源初始化并行池。此数据源将ODBC驱动程序配置为具有Windows®身份验证的Microsoft®SQL Server®数据库。请指定空用户名和密码。

数据源="MS SQL Server认证";用户名="";密码="";c = createConnectionForPool(池,数据源,用户名,密码);

定义SQL查询。

Sqlqueries = [“SELECT * FROM发票”...“SELECT * FROM inventorytable”...SELECT * FROM producttable];

调用查询篮来并行化数据访问parfor函数。

对于每个worker,检索数据库连接对象,执行SQL查询,并在本地导入数据。

parfori = 1:长度(sqlqueries) conn = c.Value;结果= fetch(conn,sqlqueries(i));Allresults {i} = results;结束

显示所有查询的结果。单元格数组包含三个表,每个表对应一组查询结果。

allresults
allresults =1×3单元格数组{10×5表}{13×4表}{15×5表}

关闭并行池。

删除(池);

使用JDBC数据库连接,使用并行池访问数据库(需要并行计算工具箱™)。从多个SQL查询中并行导入数据。

要使用JDBC数据库连接初始化并行池,必须配置JDBC数据源。有关更多信息,请参见databaseConnectionOptions函数。

启动并行池。

Pool = gcp;
使用“本地”配置文件启动并行池(parpool)…连接到并行池(工人数:6)。

使用JDBC数据源初始化并行池MSSQLServerJDBCAuth.此数据源将JDBC驱动程序配置为具有Windows®身份验证的Microsoft®SQL Server®数据库。请指定空用户名和密码。

数据源=“MSSQLServerJDBCAuth”;用户名="";密码="";c = createConnectionForPool(池,数据源,用户名,密码);

定义SQL查询。

Sqlqueries = [“SELECT * FROM发票”...“SELECT * FROM inventorytable”...SELECT * FROM producttable];

调用查询篮来并行化数据访问parfor函数。

对于每个worker,检索数据库连接对象,执行SQL查询,并在本地导入数据。

parfori = 1:长度(sqlqueries) conn = c.Value;结果= fetch(conn,sqlqueries(i));Allresults {i} = results;结束

显示所有查询的结果。单元格数组包含三个表,每个表对应一组查询结果。

allresults
allresults =1×3单元格数组{10×5表}{13×4表}{15×5表}

关闭并行池。

删除(池);

输入参数

全部折叠

平行池,指定为a平行的。池(并行计算工具箱)对象。

数据源名称,指定为字符向量或字符串标量。指定现有数据源的名称。

例子:“一个”

数据类型:字符|字符串

访问数据库所需的用户名,指定为字符向量或字符串标量。如果不需要用户名,请指定为空值""

数据类型:字符|字符串

访问数据库所需的密码,指定为字符向量或字符串标量。如果不需要密码,请指定为空值""

数据类型:字符|字符串

输出参数

全部折叠

parallel.pool.Constant,指定为parallel.pool.Constant(并行计算工具箱)对象。属性的Value属性parallel.pool.Constant对象仅在工作者上可用。

版本历史

在R2019a中引入