运行函数

DBConnection::run 方法除了运行脚本之外，还提供了一个同名重载方法来执行 DolphinDB 内置或用户自定义函数。该方法声明如下：

ConstantSP run(const string& funcName, vector<ConstantSP>& args, int priority=4, int parallelism=2, int fetchSize=0, bool clearMemory = false);

参数

  • funcName：表示待执行的函数名。
  • args：表示该函数的参数。
  • priority：表示优先级，默认是 4。
  • parallelism：表示并行度，默认是 64。
  • fetchSize：对于大数据量的表，为防止内存占用过多，API 提供了分段读取方法，默认值是0。
  • clearMemory：表示是否在执行结束后清理内存，默认为 false。

返回值

返回脚本执行结果。

使用示例

以下 2 个示例程序将展示通过 run 方法来调用 DolphinDB 内置 add 函数，其中 add 函数需要两个参数：x 和 y。

例子1：当参数 x 和 y 都只存在于 C++应用中时，用法如下：

vector<ConstantSP> args;
ConstantSP x = Util::createVector(DT_DOUBLE, 3); //构造参数x
double array_x[] = {1.5, 2.5, 7}; 
x->setDouble(0, 3, array_x);
args.push_back(x);

ConstantSP y = Util::createVector(DT_DOUBLE, 3); //构造参数y 
double array_y[] = {8.5, 7.5, 3}; 
y->setDouble(0, 3, array_y); 
args.push_back(y);
    
ConstantSP result = conn.run("add", args);  //执行函数add
    
std::cout << result->getString() << std::endl;  //输出结果[10, 10, 10]

例子2：当参数 y 存在于 server 端，参数 x 存在于 C++应用中时，此时需要使用“部分应用”方式，把参数 y 固化在 add 函数内。具体请参考：部分应用。

conn.run("y = [1, 3, 5]"); //在server端定义向量y
    
vector<ConstantSP> args;
ConstantSP x = Util::createVector(DT_DOUBLE, 3); //在C++应用中构造参数x
double array_x[] = {9, 7, 5};
x->setDouble(0, 3, array_x);
args.push_back(x);

ConstantSP result = conn.run("add{,y}", args);   //执行函数add

std::cout << result->getString() << std::endl;   //输出结果[10, 10, 10]