Запрос данных путем объединения двух таблиц в две базы данных на разных серверах

Есть две таблицы в двух разных базах данных на разных серверах, мне нужно объединить их, чтобы сделать несколько запросов. Какие у меня есть варианты? Что я должен делать?

Вам нужно будет использовать sp_addlinkedserverдля создания ссылки на сервер. См. Справочную документацию по использованию. Как только связь с сервером будет установлена, вы создадите запрос как обычно, просто добавив к имени базы данных префикс другого сервера. IE:

-- FROM DB1
SELECT *
FROM [MyDatabaseOnDB1].[dbo].[MyTable] tab1
    INNER JOIN [DB2].[MyDatabaseOnDB2].[dbo].[MyOtherTable] tab2
        ON tab1.ID = tab2.ID

Как только связь установлена, вы также можете использовать ее OPENQUERYдля выполнения инструкции SQL на удаленном сервере и передачи вам обратно только данных. Это может быть немного быстрее и позволит удаленному серверу оптимизировать ваш запрос. Если вы кэшируете данные во временной таблице (или в памяти) DB1в приведенном выше примере, вы сможете запросить их так же, как присоединение к стандартной таблице. Например:

-- Fetch data from the other database server
SELECT *
INTO #myTempTable
FROM OPENQUERY([DB2], 'SELECT * FROM [MyDatabaseOnDB2].[dbo].[MyOtherTable]')

-- Now I can join my temp table to see the data
SELECT * FROM [MyDatabaseOnDB1].[dbo].[MyTable] tab1
    INNER JOIN #myTempTable tab2 ON tab1.ID = tab2.ID

Ознакомьтесь с документацией по OPENQUERY, чтобы увидеть еще несколько примеров. Приведенный выше пример довольно надуманный. Я бы определенно использовал первый метод в этом конкретном примере, но использование второго варианта OPENQUERYможет сэкономить время и производительность, если вы используете запрос для фильтрации некоторых данных.

Попробуй это:

SELECT tab2.column_name  
FROM  [DB1.mdf].[dbo].[table_name_1] tab1 INNER JOIN [DB2.mdf].[dbo].[table_name_2]  tab2   
    ON tab1.col_name = tab2.col_name

Если связанный сервер не разрешен вашей dba, вы можете использовать OPENROWSET. Электронная документация предоставит вам необходимый синтаксис.

С практической точки зрения предприятия лучше всего сделать зеркальную копию таблицы базы данных в вашей базе данных, а затем просто сделать так, чтобы задача / процесс обновляла ее каждый час с дельтой.

Соединение двух таблиц лучше всего выполнять с помощью СУБД, поэтому это и нужно делать. Вы можете отразить меньшую таблицу или ее подмножество в одной из баз данных, а затем присоединиться к ним. У кого-то может возникнуть соблазн сделать это на сервере ETL, таком как informatica, но я думаю, это не рекомендуется, если таблицы огромны.

Если опция связи с базой данных недоступна, вы можете выбрать другой путь - связать таблицы через ODBC с чем-то вроде отчетов MS Access или Crystal и выполнить там соединение.

Возможно, жестко запрограммированные имена баз данных не всегда лучший подход в рамках SQL-запроса. Таким образом, добавление синонимов было бы лучшим подходом. Не всегда базы данных имеют одно и то же имя в нескольких промежуточных средах. Они могут состоять из таких постфиксов, как PROD, UAT, SIT, QA и т. Д. Так что помните о жестко запрограммированных запросах и сделайте их более динамичными.

Подход №1: используйте синонимы для связи таблиц между базами данных на одном сервере.

Подход № 2: Собирайте данные отдельно из каждой базы данных и присоединяйте их в своем коде. Строки подключения к базе данных могут быть частью конфигурации сервера приложений через базу данных или файл конфигурации.

Я пробовал этот код ниже, и он отлично работает

SELECT        TimeTrackEmployee.StaffID
FROM            dbo.tblGBSTimeCard AS GBSTimeCard INNER JOIN
                         TimeTrak.dbo.tblEmployee AS TimeTrackEmployee ON GBSTimeCard.[Employee Number] = TimeTrackEmployee.GBSStaffID

Вы можете попробовать следующее:

select customer1.Id,customer1.Name,customer1.city,CustAdd.phone,CustAdd.Country
from customer1
inner join [EBST08].[Test].[dbo].[customerAddress] CustAdd
on customer1.Id=CustAdd.CustId

для этого просто следуйте нижеприведенному запросу

select a.Id,a.type,b.Name,b.City from DatabaseName.dbo.TableName a left join DatabaseName.dbo.TableName b on a.Id=b.Id

Там, где я написал имя базы данных, вы должны указать имя базы данных. Если вы находитесь в той же базе данных, поэтому вам не нужно определять имя базы данных, но если вы находитесь в другой базе данных, вы должны указать имя базы данных в качестве пути, иначе она покажет вам ошибку. Надеюсь, я облегчил твою работу

Хотя у меня возникли проблемы с объединением этих двух таблиц, я сделал именно то, что хотел, открыв обе удаленные базы данных одновременно. MySQL 5.6 (php 7.1) и другие MySQL 5.1 (php 5.6)

//Open a new connection to the MySQL server
$mysqli1 = new mysqli('server1','user1','password1','database1');
$mysqli2 = new mysqli('server2','user2','password2','database2');

//Output any connection error
if ($mysqli1->connect_error) {
    die('Error : ('. $mysqli1->connect_errno .') '. $mysqli1->connect_error);
} else { 
echo "DB1 open OK<br>";
}
if ($mysqli2->connect_error) {
    die('Error : ('. $mysqli2->connect_errno .') '. $mysqli2->connect_error);
} else { 
echo "DB2 open OK<br><br>";
}

Если вы получили эти два сообщения ОК на экране, значит, обе базы данных открыты и готовы. Затем вы можете приступить к выполнению своих запросов.

$results = $mysqli1->query("SELECT * FROM video where video_id_old is NULL");
    while($row = $results->fetch_array()) {
        $theID = $row[0];
        echo "Original ID : ".$theID." <br>";
        $doInsert = $mysqli2->query("INSERT INTO video (...) VALUES (...)");
        $doGetVideoID = $mysqli2->query("SELECT video_id, time_stamp from video where user_id = '".$row[13]."' and time_stamp = ".$row[28]." ");
            while($row = $doGetVideoID->fetch_assoc()) {
                echo "New video_id : ".$row["video_id"]." user_id : ".$row["user_id"]." time_stamp : ".$row["time_stamp"]."<br>";
                $sql = "UPDATE video SET video_id_old = video_id, video_id = ".$row["video_id"]." where user_id = '".$row["user_id"]."' and video_id = ".$theID.";";
                $sql .= "UPDATE video_audio SET video_id = ".$row["video_id"]." where video_id = ".$theID.";";
                // Execute multi query if you want
                if (mysqli_multi_query($mysqli1, $sql)) {
                    // Query successful do whatever...
                }
            }
    }
// close connection 
$mysqli1->close();
$mysqli2->close();

Я пытался сделать несколько соединений, но поскольку у меня открыты эти две БД, я могу перемещаться вперед и назад, выполняя запросы, просто изменяя соединение $mysqli1или$mysqli2

У меня сработало, надеюсь, поможет ... Ура