将数组插入 MongoDB

Question

我在 MySQL 中有一个名为 new_ndnc 的表，其中包含五个字段。每个字段包含 1000 万行。

我已将每个字段读入一个数组，现在我想将整个数组插入到 MongoDB 中的一个字段中。

我的代码如下。

#!/usr/bin/perl

use MongoDB;
use MongoDB::OID;
use DBI;

$dbs  = 'amrit';
$user = 'root';
$pass = 'walkover';
$dbh  = DBI->connect("DBI:mysql:database=$dbs", $user, $pass)
    or die "Cannot connect to MySQL server\n";

$conn = MongoDB::Connection->new(
  host    => 'localhost',
  port    => 27017,
  db_name => 'amrit'
);
$db     = $conn->get_database('amrit');
$users  = $db->get_collection('hell2');

$abcuid = $dbh->prepare('select Service_Area_Code from new_ndnc');
$abcuid->execute;

@uid;
while (my @row = $abcuid->fetchrow_array()) {
  push(@uid, @row);
}
$hh = $dbh->prepare('select phonenumbers from new_ndnc');
$hh->execute;

@route1;
while (my @row = $hh->fetchrow_array()) {
  push(@route1, @row);
}

$r4 = $dbh->prepare('select Preferences from new_ndnc');
$r4->execute;

@route4;
while (my @row = $r4->fetchrow_array()) {
  push(@route4, @row);
}
$exr4 = $dbh->prepare('select Opstype from new_ndnc');
$exr4->execute;

@exroute4;
while (my @row = $exr4->fetchrow_array()) {
  push(@exroute4, @row);
}
$r5 = $dbh->prepare('select PhoneType from new_ndnc');
$r5->execute;

@route5;
while (my @row = $r5->fetchrow_array()) {
  push(@route5, @row);
}

$users->insert({
    'UserID'           => "[@uid]",
    'route1'           => "[@route1]",
    'route4'           => "[@route4]",
    'route4_extra_bal' => "[@exroute4]",
    'route5'           => "[@route5]"
  }
);

Answer 1

在重新阅读您的代码时，您的方法都是错误的。您正在做的是一次将所有内容从表中拉出一列，将每个行值推入一个数组并尝试将其写入 MongoDB。就目前而言，您正在尝试在 MongoDB 中编写一个文档，该文档的每个字段都包含表中的每个行值。这肯定是你不想要的。

你可能，实际上想要做的是：

1. 从表中选择要放入每个 mongo 字段中的列的结果。并在一个查询中执行此操作。

2. 在获取表的行时，将每个文档插入到 MongoDB 集合中。

您的另一个误解是 ObjectId (OID)。每个 MongoDB 文档都有一个默认字段 _id，如果您没有在插入时明确指定此值，则该值将自动填充。如果您确实有一个不会重复的合理的自然 主键，那么您可以将其放入该字段。在 HashRef 表示法中，{ '_id' => 'key_value' }。

要更轻松地将表行转换为向 MongoDB 中插入行所需的 HashRef 结构，请查看 DBI 文档中的 fetchrow_hashref。

除此之外，很难提出建议，因为您的代码有点funky，而且还不清楚您真正想要做什么。这些显然不是小数组，因此您不想尝试将所有这些值推送到一个文档中。