update_records

Updates the data in the table on the database connected with the built-in PostgreSQL and SQL Connection.

morph_lib.database

# 📦 Package: morph_lib.database
# 🛠️ Function: update_records

update_records(
	data: pd.DataFrame,
	primary_keys: List[str]
	table_name: str,
	connection: Optional[str]
) -> None

対応データベース

PostgreSQL
MySQL
Snowflake
BigQuery
Amazon Redshift

Parameters

data

pd.DataFrame

required

The actual data to be passed to the function. The columns specified in primary_keys must exist.

primary_keys

List[str]

required

Specify the column names that will be the Primary Key of the table.

table_name

str

required

Specify the table name.

connection

str

The destination of the connection other than the built-in registered on the screen (optional)

If not specified, it will be set to the built-in PostgreSQL.

Example

from morph_lib.database import update_records

@morph.func
@morph.load_data("user_data")
def func_name(context):
	user_data: pd.DataFrame = context.data["user_data"]
	update_records(
		user_data,
		["user_id"]
		"user",
	)

Framework

SQL

Python

morph_lib.database

morph_lib.api

morph_lib.stream

CLI

Deprecated

update_records

Parameters

Example

​Parameters

​Example

Parameters

Example