Использование SQL Azure Federations через PHP

Вставить данные

После того, как мы создали объект федерации и член федерации, вставка данных практически такая же, как и для SQL Server. Разница лишь в том, что нам нужно сначала подключиться к члену федерации. (Примечание № 2 выше относится и к этому примеру кода.)

$sql1 = "USE FEDERATION Orders_Federation (CustId = 0) WITH RESET, FILTERING = OFF;";
$stmt = sqlsrv_query($conn, $sql1);
if($stmt === false)
    die(print_r(sqlsrv_errors()));
else
    echo "Connected to Orders_Federation!<br />";
    
$sql2 = "INSERT INTO Products (ProductID, SupplierID, ProductName, Price)
        VALUES ( 386, 1001,    'Titanium Extension Bracket Left Hand',    5.25 )
        
        INSERT INTO Products (ProductID, SupplierID, ProductName, Price)
        VALUES ( 387, 1001,    'Titanium Extension Bracket Right Hand', 5.25 )
        
        INSERT INTO Products (ProductID, SupplierID, ProductName, Price)
        VALUES ( 388, 1001,    'Fusion Generator Module 5 kV',    10.50 )
        
        INSERT INTO Products (ProductID, SupplierID, ProductName, Price)
        VALUES ( 389, 1001,    'Bypass Filter 400 MHz Low Pass', 10.50 )
        
 
        INSERT INTO Customers (CustomerID, CompanyName, FirstName, LastName)
        VALUES (10, 'Van Nuys', 'Catherine', 'Abel')
        
        INSERT INTO Customers (CustomerID, CompanyName, FirstName, LastName)
        VALUES (20, 'Abercrombie', 'Kim', 'Branch')
        
        INSERT INTO Customers (CustomerID, CompanyName, FirstName, LastName)
        VALUES (30, 'Contoso', 'Frances', 'Adams')
        
        INSERT INTO Customers (CustomerID, CompanyName, FirstName, LastName)
        VALUES (40, 'A. Datum Corporation', 'Mark', 'Harrington')
        
        INSERT INTO Customers (CustomerID, CompanyName, FirstName, LastName)
        VALUES (50, 'Adventure Works', 'Keith', 'Harris')
        
        INSERT INTO Customers (CustomerID, CompanyName, FirstName, LastName)
        VALUES (60, 'Alpine Ski House', 'Wilson', 'Pais')
        
        INSERT INTO Customers (CustomerID, CompanyName, FirstName, LastName)
        VALUES (70, 'Baldwin Museum of Science', 'Roger', 'Harui')
        
        INSERT INTO Customers (CustomerID, CompanyName, FirstName, LastName)
        VALUES (80, 'Blue Yonder Airlines', 'Pilar', 'Pinilla')
        
        INSERT INTO Customers (CustomerID, CompanyName, FirstName, LastName)
        VALUES (90, 'City Power & Light', 'Kari', 'Hensien')
        
        INSERT INTO Customers (CustomerID, CompanyName, FirstName, LastName)
        VALUES (100, 'Coho Winery', 'Peter', 'Brehm')

        

        DECLARE @orderId INT
        DECLARE @customerId INT
 
        SET @orderId = 10
        SELECT @customerId = CustomerId FROM Customers WHERE LastName = 'Hensien' and FirstName = 'Kari'
 
        INSERT INTO Orders (CustomerId, OrderId, OrderDate)
        VALUES (@customerId, @orderId, GetDate())
 
        INSERT INTO OrderItems (CustomerID, OrderID, ProductID, Quantity)
        VALUES (@customerId, @orderId, 388, 4)
 
        SET @orderId = 20
        SELECT @customerId = CustomerId FROM Customers WHERE LastName = 'Harui' and FirstName = 'Roger'
 
        INSERT INTO Orders (CustomerId, OrderId, OrderDate)
        VALUES (@customerId, @orderId, GetDate())
 
        INSERT INTO OrderItems (CustomerID, OrderID, ProductID, Quantity)
        VALUES (@customerId, @orderId, 389, 2)
 
        SET @orderId = 30
        SELECT @customerId = CustomerId FROM Customers WHERE LastName = 'Brehm' and FirstName = 'Peter'
 
        INSERT INTO Orders (CustomerId, OrderId, OrderDate)
        VALUES (@customerId, @orderId, GetDate())
 
        INSERT INTO OrderItems (CustomerID, OrderID, ProductID, Quantity)
        VALUES (@customerId, @orderId, 387, 3)
 
        SET @orderId = 40
        SELECT @customerId = CustomerId FROM Customers WHERE LastName = 'Pais' and FirstName = 'Wilson'
 
        INSERT INTO Orders (CustomerId, OrderId, OrderDate)
        VALUES (@customerId, @orderId, GetDate())
 
        INSERT INTO OrderItems (CustomerID, OrderID, ProductID, Quantity)
        VALUES (@customerId, @orderId, 388, 1)
        ";

$stmt2 = sqlsrv_query($conn, $sql2);
if($stmt2 === false)
    die(print_r(sqlsrv_errors()));
else
    echo "Data inserted. <br />";

Код подключения для приведенного выше примера такой же, как в разделе «Создание федеративных таблиц».

Разделить федерацию

Вот где действительно начинает показывать ценность SQL Azure Federations. Теперь, когда мой первый член федерации начинает заполняться данными, я могу выполнить запрос, который создаст второго члена федерации и переместит данные из первого члена во второй. В приведенном ниже примере я перемещаю все данные с CustId> = 60 во вторую федерацию:

Разделение занимает несколько минут. Если вы подождете несколько минут после выполнения запроса, а затем выполните запрос в разделе «Просмотр элементов федерации» выше, вы должны увидеть что-то вроде этого:

Как видите, в нашей федерации сейчас два члена. Первый член содержит данные с CustId, которые идут от нижней части диапазона INT до (но не включая) 60, а второй член содержит CustId> = 60. По мере роста наших данных мы можем выполнять больше команд разделения для объединения наших данных. через больше членов.

Вставка данных после разделения

Логический вопрос, который нужно задать после разделения федерации: «Как вставить данные в мои федеративные таблицы?» Ответ прост: сгенерируйте новый ключ распространения, подключитесь к соответствующему члену федерации и вставьте. К счастью, легко подключиться к соответствующему члену федерации: просто укажите CustId = (новый Id) в запросе USE FEDERATION . Таким образом, добавление нового клиента, заказа и позиции заказа с CustId = 55 может выглядеть примерно так:

$sql1 = "USE FEDERATION Orders_Federation (CustId = 55) WITH RESET, FILTERING = OFF;";
$stmt = sqlsrv_query($conn, $sql1);
if($stmt === false)
    die(print_r(sqlsrv_errors()));
else
    echo "Connected to Orders_Federation!<br />";
 
$params2 = array(55, 37);    
$sql2 = "DECLARE @customerId INT
        SET @customerId = ?
        INSERT INTO Customers (CustomerID, CompanyName, FirstName, LastName)
        VALUES (@customerId, 'Microsoft', 'Swan', 'Brian')
 
        DECLARE @orderId INT
        SET @orderId = ?
        
        INSERT INTO Orders (CustomerId, OrderId, OrderDate)
        VALUES (@customerId, @orderId, GetDate())
 
        INSERT INTO OrderItems (CustomerID, OrderID, ProductID, Quantity)
        VALUES (@customerId, @orderId, 389, 1)";
        
$stmt2 = sqlsrv_query($conn, $sql2, $params2);
if($stmt2 === false)
    die(print_r(sqlsrv_errors()));
else
    echo "Data inserted. <br />";

Чтобы вернуть эти данные, см. Раздел « Запрос члена федерации с включенной фильтрацией » ниже.

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

Запросить члена федерации с отключенной фильтрацией

Чтобы получить данные, мы (снова) подключаемся к члену федерации. Чтобы определить, к какому члену мы подключаемся, мы указываем значение для ключа распределения федерации. В приведенном ниже примере в запросе USE FEDERATION указано CustId = 0 , поэтому мы подключены к члену, диапазон которого содержит CustId 0. Поскольку в запросе FILTERING = OFF, возвращаются все данные от члена федерации (т. Е. данные не фильтруются указанным CustId). в этом случае все данные из таблицы Customers возвращаются указанным членом федерации:

// Query federation member
$sql1 = "USE FEDERATION Orders_Federation (CustId = 0) WITH RESET, FILTERING = OFF;";
$stmt1 = sqlsrv_query($conn, $sql1);
if($stmt1 === false)
    die(print_r(sqlsrv_errors()));
else
    echo "Connected to Orders_Federation!<br />";
    
$sql2 = "SELECT * FROM Customers";
$stmt2 = sqlsrv_query($conn, $sql2);
if($stmt2 === false)
    die(print_r(sqlsrv_errors()));
else
    echo "Data retrieved. <br />";
 
while($row = sqlsrv_fetch_array($stmt2, SQLSRV_FETCH_ASSOC))
{
    echo "<pre>";
    print_r($row);
    echo "</pre>";
}

Код подключения для этого примера такой же, как в примере создания федеративных таблиц .

Запрос члена федерации с включенной фильтрацией

В этом примере я подключусь ко второму члену федерации, указав CustId, который попадает в диапазон для этого члена. Я также установлю FILTERING = ON при подключении к члену федерации. Это отфильтрует возвращаемые данные по указанному CustId, поэтому мы вернем только данные, связанные с CustId = 90. (Если мы установим FILTERING = OFF, мы получим все данные от члена федерации).

$serverName = "tcp:SERVERID.database.windows.net, 1433"; 
$connectionOptions = array("Database" => "SalesDB", "UID" => "USER@SERVERID", "PWD" => "PASSWORD", "MultipleActiveResultSets" => false, "ReturnDatesAsStrings" => true);
 

$conn = sqlsrv_connect($serverName, $connectionOptions);
if($conn === false)      
    die(print_r(sqlsrv_errors(), true)); 
else
    echo "Connected via sqlsrv!<br />";
 
$sql1 = "USE FEDERATION Orders_Federation (CustId = 90) WITH RESET, FILTERING = ON;";
$stmt1 = sqlsrv_query($conn, $sql1);
if($stmt1 === false)
    die(print_r(sqlsrv_errors()));
else
    echo "Connected to Orders_Federation!<br />";
    
$sql2 = "SELECT * FROM Customers;
         SELECT * FROM Orders;
         SELECT * FROM OrderItems;";
         
$stmt2 = sqlsrv_query($conn, $sql2);
if($stmt2 === false)
    die(print_r(sqlsrv_errors()));
else
    echo "Data retrieved. <br />";
 
do{
    while($row = sqlsrv_fetch_array($stmt2, SQLSRV_FETCH_ASSOC))
    {
        echo "<pre>";
        print_r($row);
        echo "</pre>";
    }
}while(sqlsrv_next_result($stmt2));

Обратите внимание, что я немного изменил код подключения: ReturnDatesAsStrings установлен в true в $ connectionOptions .

Вот вывод:

Дополнительные замечания

Одним из потенциальных недостатков текущей реализации федераций SQL Azure является отсутствие простого способа сокращения членов федерации. Как видите, добавить участников федерации и распределить данные по ним легко, но в настоящее время не так просто объединить данные в меньшее количество членов федерации. Команда SQL Azure ищет способы упростить масштабирование.

Дополнительные ресурсы

Начало работы с PHP и SQL Azure

Введение в разветвленные запросы

http://blogs.msdn.com/b/cbiyikoglu/

Справочник по Transact-SQL (база данных SQL Azure)

Вот и все пока … просто введение в федерации SQL Azure, действительно. Чтобы получить более глубокий взгляд, ознакомьтесь с некоторыми из дополнительных ресурсов выше.

Спасибо.

-Брайан

Источник: http://blogs.msdn.com/b/silverlining/archive/2012/01/18/using-sql-azure-federations-via-php.aspx