database()

Описание

Функция database() возвращает имя текущей базы данных в сессии Spark SQL. Это полезно для получения контекста текущей базы данных при выполнении запросов.

Возвращаемое значение

Column - строка с именем текущей базы данных

Пример использования

from pyspark.sql import SparkSession

# Создаем SparkSession
spark = SparkSession.builder.appName("database_example").getOrCreate()

# Получаем имя текущей базы данных
current_db = spark.sql("SELECT database()").collect()[0][0]
print(f"Текущая база данных: {current_db}")

# Создаем новую базу данных и переключаемся на нее
spark.sql("CREATE DATABASE IF NOT EXISTS test_db")
spark.sql("USE test_db")

# Проверяем новую текущую базу данных
new_db = spark.sql("SELECT database()").collect()[0][0]
print(f"Новая текущая база данных: {new_db}")

Примечания

• Возвращает имя базы данных по умолчанию, если не указана другая
• Может использоваться в SQL-запросах и DataFrame API
• Связанные функции:
• current_database() - синоним функции database()
• current_schema() - возвращает текущую схему
• current_catalog() - возвращает текущий каталог