PUT INTO¶

PUT INTO operates like a standard INSERT statement.

For Column Tables¶

If you need the putInto() functionality for column tables, you must specify key_columns while defining the column table. PUT INTO updates the row if present, else, it inserts the row. As column tables do not have the primary key functionality, you must specify key_columns when creating the table. These columns are used to identify a row uniquely. PUT INTO is available by SQL as well APIs.

Syntax¶

PUT INTO <TABLENAME> SELECT V1, V2, V3,......,Vn;

PUT INTO <schema name>.<table name2> SELECT * from <schema name>.<table name1>;

PUT INTO <schema name>.<table name2> SELECT * from <schema name>.<table name1> WHERE <column name>='<Value>'

PUT INTO <schema name>.<table name2> SELECT from <schema name>.<table name1> WHERE <column name>='<Value>'

PUT INTO <schema name>.<table name> VALUES (V1, V2,... ,Vn);

Examples¶

For SQL

// Insert into another table using a select statement for column tables with key columns

PUT INTO TRADE.CUSTOMERS SELECT '1','2','hello';

PUT INTO TRADE.NEWCUSTOMERS SELECT * from CUSTOMERS;

PUT INTO TRADE.NEWCUSTOMERS SELECT * from CUSTOMERS WHERE C_NAME='User 1';

PUT INTO TRADE.NEWCUSTOMERS SELECT from CUSTOMERS WHERE C_NAME='User 1';

PUT INTO TRADE.CUSTOMERS VALUES (1, 'User 1', '2001-10-12', 'SnappyData', 1);
PUT INTO TRADE.CUSTOMERS (CID ,CUST_NAME , ADDR ,TID) VALUES (1, 'User 1' , 'SnappyData', 1);

For API

putInto API is available from the DataFrameWriter extension.

import org.apache.spark.sql.snappy._
dataFrame.write.putInto("col_table")

For Row Tables¶

PUT INTO uses a syntax similar to the INSERT statement, but SnappyData does not check the existing primary key values before executing the PUT INTO command. If a row with the same primary key exists in the table, PUT INTO overwrites the older row value. If no rows with the same primary key exist, PUT INTO operates like a standard INSERT. This behavior ensures that only the last primary key value inserted or updated remains in the system, which preserves the primary key constraint. Removing the primary key check speeds execution when importing bulk data.

The PUT INTO statement is similar to the "UPSERT" command or capability provided by other RDBMS to relax primary key checks. By default, the PUT INTO statement ignores only primary key constraints.

Syntax¶

PUT INTO <schema name>.<table name> VALUES (V1, V2,... ,Vn);

Example¶

PUT INTO TRADE.CUSTOMERS VALUES (1, 'User 1', '2001-10-12', 'SnappyData', 1);

When specifying columns with table, columns should not have any CONSTRAINT, as explained in the following example:

PUT INTO TRADE.CUSTOMERS (CID ,CUST_NAME , ADDR ,TID) VALUES (1, 'User 1' , 'SnappyData', 1), (2, 'User 2' , 'SnappyData', 1);

PUT into another table using a select statement

PUT INTO TRADE.NEWCUSTOMERS SELECT * from TRADE.CUSTOMERS;

PUT INTO TRADE.NEWCUSTOMERS SELECT * from TRADE.CUSTOMERS WHERE CUST_NAME='User 1'