查询SQL Server数据砖

本文将展示如何连接砖Microsoft SQL server来读取和写入数据。

请注意

你可能更喜欢Lakehouse联合会管理对SQL Server数据查询。看到使用Lakehouse联合运行查询。

配置连接到SQL server

在砖运行时11.3 LTS以上,您可以使用sqlserver关键字使用包括驱动程序连接到SQL server。在处理DataFrames时,使用下面的语法:

              remote_table=(火花。读。格式(”“状态"置疑")。选项(“主机”,“主机名”)。选项(“端口”,“端口”)#可选的,可以使用默认端口1433如果省略。选项(“用户”,“用户名”)。选项(“密码”,“密码”)。选项(“数据库”,“数据库名”)。选项(“数据表”,“schemaName.tableName”)#(如果schemaName不提供,默认为“dbo”)。负载())
             

              瓦尔remote_table=火花。读。格式(”“状态"置疑")。选项(“主机”,“主机名”)。选项(“端口”,“端口”)/ /可选的,可以使用默认端口1433如果省略。选项(“用户”,“用户名”)。选项(“密码”,“密码”)。选项(“数据库”,“数据库名”)。选项(“数据表”,“schemaName.tableName”)/ /(如果schemaName不提供,默认为“dbo”)。负载()
             

使用SQL时,指定sqlserver在使用条款和传递选项在创建一个表,如以下示例所示:

             下降表如果存在sqlserver_table;创建表sqlserver_table使用sqlserver选项(数据表“< schema-name.table-name >”,主机“<主机名>”,港口“1433”,数据库“<数据库名称>”,用户“<用户名>”,密码“<密码>”);
            

使用遗留JDBC驱动程序

在砖运行时的11.2和下面,您必须指定使用JDBC驱动程序和配置设置。下面的示例查询SQL Server使用JDBC驱动程序。为更多的细节在阅读,写作,配置并行性,和查询下推,看到的使用JDBC查询数据库。

              司机=“com.microsoft.sqlserver.jdbc.SQLServerDriver”database_host=“< database-host-url >”database_port=“1433”如果你使用非默认端口#更新database_name=“<数据库名称>”表=“<表名称>”用户=“<用户名>”密码=“<密码>”url=f" jdbc::状态"置疑" / /{database_host}:{database_port};数据库={database_name}”remote_table=(火花。读。格式(“jdbc”)。选项(“司机”,司机)。选项(“url”,url)。选项(“数据表”,表)。选项(“用户”,用户)。选项(“密码”,密码)。负载())
             

              瓦尔司机=“com.microsoft.sqlserver.jdbc.SQLServerDriver”瓦尔database_host=“< database-host-url >”瓦尔database_port=“1433”/ /更新如果你使用非默认端口瓦尔database_name=“<数据库名称>”瓦尔表=“<表名称>”瓦尔用户=“<用户名>”瓦尔密码=“<密码>”瓦尔url=s " jdbc::状态"置疑" / / {database_host}: {database_port};数据库= {database_name} "瓦尔remote_table=火花。读。格式(“jdbc”)。选项(“司机”,司机)。选项(“url”,url)。选项(“数据表”,表)。选项(“用户”,用户)。选项(“密码”,密码)。负载()
             