db-object-snowflake.ddl

-- change the role 
USE ROLE ACCOUNTADMIN;

-- create necessary database objects

CREATE DATABASE KAFKA_CONNECT_DB;
CREATE ROLE KAFKA_CONNECT_ROLE;
CREATE SCHEMA KAFKA_CONNECT_DB.KAFKA_CONNECT_SCHEMA;
CREATE TABLE KAFKA_TABLE_IN (RECORD_METADATA VARIANT, RECORD_CONTENT VARIANT);
CREATE WAREHOUSE KAFKA_WAREHOUSE WITH WAREHOUSE_SIZE = 'XSMALL' WAREHOUSE_TYPE = 'STANDARD' AUTO_SUSPEND = 300 AUTO_RESUME = TRUE;

--create necessary grants
GRANT USAGE ON DATABASE KAFKA_CONNECT_DB to role KAFKA_CONNECT_ROLE;
GRANT USAGE ON SCHEMA KAFKA_CONNECT_DB.KAFKA_CONNECT_SCHEMA TO ROLE KAFKA_CONNECT_ROLE;
GRANT CREATE TABLE ON SCHEMA KAFKA_CONNECT_DB.KAFKA_CONNECT_SCHEMA TO ROLE KAFKA_CONNECT_ROLE;
GRANT CREATE STAGE ON SCHEMA KAFKA_CONNECT_DB.KAFKA_CONNECT_SCHEMA TO ROLE KAFKA_CONNECT_ROLE;
GRANT CREATE PIPE ON SCHEMA KAFKA_CONNECT_DB.KAFKA_CONNECT_SCHEMA TO ROLE KAFKA_CONNECT_ROLE;
GRANT OWNERSHIP ON TABLE KAFKA_TABLE_IN to role KAFKA_CONNECT_ROLE;

--!!!!!!!!!!!update the username with your username
GRANT ROLE "KAFKA_CONNECT_ROLE" TO USER "YOURUSERNAME";

GRANT USAGE ON WAREHOUSE "KAFKA_WAREHOUSE" TO ROLE "KAFKA_CONNECT_ROLE";

--!!!!!!!!!!!set default to the newly created one. Please note if you dont perform this step, you will get error while running the connector.
ALTER USER YOURUSERNAME set DEFAULT_ROLE = KAFKA_CONNECT_ROLE;

--!!!!!!!!!!!set the rsa public key that you generated in step 2 above.
ALTER USER SUDHENDUP SET rsa_public_key='thepublickeyyougenerated';