接続 後、SQL ステートメントを実行して結果を取得できます。

SELECT プロシージャ

sqlQuery 関数を使って、クエリを実行できます。デフォルトでは、すべての結果を単一のデータフレームとして返します。これは小さな結果セットに向いています。

results <- sqlQuery(cnx, "SELECT Type, DatasetName FROM Schemas WHERE ProjectId = 'bigquery-public-data'")
for (row in 1:nrow(results)) {
    cat(paste("Type = ", results[row,]$Type, "\n"))
    cat(paste("DatasetName = ", results[row,]$DatasetName, "\n"))
}

結果の反復処理

より大きな結果セットの場合、sqlQuery は結果セット全体をメモリに格納する代わりにバッチで結果を返すことができます。結果が残っていない場合やエラーが発生した場合は、sqlQuery およびsqlGetResults はデータフレームの代わりに整数のエラーコードを返します。

results <- sqlQuery(cnx, "SELECT Type, DatasetName FROM Schemas WHERE ProjectId = 'bigquery-public-data'", max = 1000)
while (is.data.frame(results)) {
    for (row in 1:nrow(results)) {
        cat(paste("Type = ", results[row,]$Type))
        cat(paste("DatasetName = ", results[row,]$DatasetName))
    }
    rows <- sqlGetResults(cnx, max = 1000)
}