fix: log fmt (#1192)

pkg/datasources/current_account.go

@@ -43,7 +43,7 @@ func ReadCurrentAccount(d *schema.ResourceData, meta interface{}) error {
 	acc, err := snowflake.ReadCurrentAccount(db)
 
 	if err != nil {
-		log.Printf("[DEBUG] current_account failed to decode")
+		log.Println("[DEBUG] current_account failed to decode")
 		d.SetId("")
 		return nil
 	}
@@ -60,7 +60,7 @@ func ReadCurrentAccount(d *schema.ResourceData, meta interface{}) error {
 	url, err := acc.AccountURL()
 
 	if err != nil {
-		log.Printf("[DEBUG] generating snowflake url failed")
+		log.Println("[DEBUG] generating snowflake url failed")
 		d.SetId("")
 		return nil
 	}

pkg/datasources/database.go

@@ -65,12 +65,12 @@ func ReadDatabase(d *schema.ResourceData, meta interface{}) error {
 	log.Printf("[DEBUG] database: %v", d.Get("name"))
 	dbData, err := snowflake.ListDatabase(dbx, d.Get("name").(string))
 	if err != nil {
-		log.Printf("[DEBUG] list database failed to decode")
+		log.Println("[DEBUG] list database failed to decode")
 		d.SetId("")
 		return nil
 	}
 	if dbData == nil || !dbData.DBName.Valid {
-		log.Printf("[DEBUG] database not found")
+		log.Println("[DEBUG] database not found")
 		d.SetId("")
 		return nil
 	}

pkg/datasources/databases.go

@@ -89,7 +89,7 @@ func ReadDatabases(d *schema.ResourceData, meta interface{}) error {
 	dbx := sqlx.NewDb(db, "snowflake")
 	dbs, err := snowflake.ListDatabases(dbx)
 	if err != nil {
-		log.Printf("[DEBUG] list databases failed to decode")
+		log.Println("[DEBUG] list databases failed to decode")
 		d.SetId("")
 		return nil
 	}

pkg/datasources/system_get_privatelink_config.go

@@ -57,14 +57,14 @@ func ReadSystemGetPrivateLinkConfig(d *schema.ResourceData, meta interface{}) er
 
 	if err == sql.ErrNoRows {
 		// If not found, mark resource to be removed from statefile during apply or refresh
-		log.Print("[DEBUG] system_get_privatelink_config not found")
+		log.Println("[DEBUG] system_get_privatelink_config not found")
 		d.SetId("")
 		return nil
 	}
 
 	config, err := rawConfig.GetStructuredConfig()
 	if err != nil {
-		log.Printf("[DEBUG] system_get_privatelink_config failed to decode")
+		log.Println("[DEBUG] system_get_privatelink_config failed to decode")
 		d.SetId("")
 		return nil
 	}

pkg/datasources/system_get_snowflake_platform_info.go

@@ -42,7 +42,7 @@ func ReadSystemGetSnowflakePlatformInfo(d *schema.ResourceData, meta interface{}
 	if err != nil {
 		// If not found, mark resource to be removed from statefile during apply or refresh
 		d.SetId("")
-		log.Printf("[DEBUG] current_account failed to decode")
+		log.Println("[DEBUG] current_account failed to decode")
 		return errors.Wrap(err, "error current_account")
 	}
 
@@ -51,13 +51,13 @@ func ReadSystemGetSnowflakePlatformInfo(d *schema.ResourceData, meta interface{}
 	rawInfo, err := snowflake.ScanSnowflakePlatformInfo(row)
 	if err == sql.ErrNoRows {
 		// If not found, mark resource to be removed from statefile during apply or refresh
-		log.Print("[DEBUG] system_get_snowflake_platform_info not found")
+		log.Println("[DEBUG] system_get_snowflake_platform_info not found")
 		return errors.Wrap(err, "error system_get_snowflake_platform_info")
 	}
 
 	info, err := rawInfo.GetStructuredConfig()
 	if err != nil {
-		log.Printf("[DEBUG] system_get_snowflake_platform_info failed to decode")
+		log.Println("[DEBUG] system_get_snowflake_platform_info failed to decode")
 		d.SetId("")
 		return errors.Wrap(err, "error system_get_snowflake_platform_info")
 	}

pkg/resources/managed_account.go

@@ -114,7 +114,7 @@ func CreateManagedAccount(d *schema.ResourceData, meta interface{}) error {
 // some time to appear. This is currently implemented as a sleep. @TODO actually
 // wait until the locator is generated.
 func initialReadManagedAccount(d *schema.ResourceData, meta interface{}) error {
-	log.Printf("[INFO] sleeping to give the locator a chance to be generated")
+	log.Println("[INFO] sleeping to give the locator a chance to be generated")
 	//lintignore:R018
 	time.Sleep(10 * time.Second)
 	return ReadManagedAccount(d, meta)

pkg/resources/resource.go

@@ -111,7 +111,7 @@ func UpdateResource(
 
 			}
 			if d.HasChange("tag") {
-				log.Printf("[DEBUG] updating tags")
+				log.Println("[DEBUG] updating tags")
 				v := d.Get("tag")
 				tags := getTags(v)
 				qb.SetTags(tags.toSnowflakeTagValues())
@@ -122,7 +122,7 @@ func UpdateResource(
 				return errors.Wrapf(err, "error altering %s", t)
 			}
 		}
-		log.Printf("[DEBUG] performing read")
+		log.Println("[DEBUG] performing read")
 		return read(d, meta)
 	}
 }

pkg/resources/tag_association.go

@@ -91,7 +91,7 @@ func CreateTagAssociation(d *schema.ResourceData, meta interface{}) error {
 
 	skipValidate := d.Get("skip_validation").(bool)
 	if !skipValidate {
-		log.Printf("[DEBUG] validating tag creation")
+		log.Println("[DEBUG] validating tag creation")
 
 		err = resource.RetryContext(context.Background(), d.Timeout(schema.TimeoutCreate)-time.Minute, func() *resource.RetryError {
 
@@ -135,7 +135,7 @@ func ReadTagAssociation(d *schema.ResourceData, meta interface{}) error {
 	tagValue := d.Get("tag_value").(string)
 	skipValidate := d.Get("skip_validation").(bool)
 	if skipValidate {
-		log.Printf("[DEBUG] skipping read for tag association that has skip_validation enabled")
+		log.Println("[DEBUG] skipping read for tag association that has skip_validation enabled")
 		return nil
 	}
 

pkg/snowflake/database.go

@@ -280,7 +280,7 @@ func ListDatabases(sdb *sqlx.DB) ([]database, error) {
 	dbs := []database{}
 	err = sqlx.StructScan(rows, &dbs)
 	if err == sql.ErrNoRows {
-		log.Printf("[DEBUG] no databases found")
+		log.Println("[DEBUG] no databases found")
 		return nil, nil
 	}
 	return dbs, errors.Wrapf(err, "unable to scan row for %s", stmt)
@@ -297,7 +297,7 @@ func ListDatabase(sdb *sqlx.DB, databaseName string) (*database, error) {
 	dbs := []database{}
 	err = sqlx.StructScan(rows, &dbs)
 	if err == sql.ErrNoRows || len(dbs) == 0 {
-		log.Printf("[DEBUG] no databases found")
+		log.Println("[DEBUG] no databases found")
 		return nil, nil
 	}
 	db := &database{}

pkg/snowflake/external_function.go

@@ -279,7 +279,7 @@ func ListExternalFunctions(databaseName string, schemaName string, db *sql.DB) (
 	dbs := []externalFunction{}
 	err = sqlx.StructScan(rows, &dbs)
 	if err == sql.ErrNoRows {
-		log.Printf("[DEBUG] no external functions found")
+		log.Println("[DEBUG] no external functions found")
 		return nil, nil
 	}
 	return dbs, errors.Wrapf(err, "unable to scan row for %s", stmt)

pkg/snowflake/external_table.go

@@ -225,7 +225,7 @@ func ListExternalTables(databaseName string, schemaName string, db *sql.DB) ([]e
 	dbs := []externalTable{}
 	err = sqlx.StructScan(rows, &dbs)
 	if err == sql.ErrNoRows {
-		log.Printf("[DEBUG] no external tables found")
+		log.Println("[DEBUG] no external tables found")
 		return nil, nil
 	}
 	return dbs, errors.Wrapf(err, "unable to scan row for %s", stmt)

pkg/snowflake/file_format.go

@@ -628,7 +628,7 @@ func ListFileFormats(databaseName string, schemaName string, db *sql.DB) ([]file
 	dbs := []fileFormatShow{}
 	err = sqlx.StructScan(rows, &dbs)
 	if err == sql.ErrNoRows {
-		log.Printf("[DEBUG] no file formats found")
+		log.Println("[DEBUG] no file formats found")
 		return nil, nil
 	}
 	return dbs, errors.Wrapf(err, "unable to scan row for %s", stmt)

pkg/snowflake/function.go

@@ -342,7 +342,7 @@ func ListFunctions(databaseName string, schemaName string, db *sql.DB) ([]functi
 	dbs := []function{}
 	err = sqlx.StructScan(rows, &dbs)
 	if err == sql.ErrNoRows {
-		log.Printf("[DEBUG] no functions found")
+		log.Println("[DEBUG] no functions found")
 		return nil, nil
 	}
 	return dbs, pe.Wrapf(err, "unable to scan row for %s", stmt)

pkg/snowflake/masking_policy.go

@@ -70,7 +70,7 @@ func (mpb *MaskingPolicyBuilder) WithReturnDataType(dataType string) *MaskingPol
 //
 // Supported DDL operations are:
 //   - CREATE MASKING POLICY
-//	 - ALTER MASKING POLICY
+//   - ALTER MASKING POLICY
 //   - DROP MASKING POLICY
 //   - SHOW MASKING POLICIES
 //   - DESCRIBE MASKING POLICY
@@ -160,7 +160,7 @@ func ListMaskingPolicies(databaseName string, schemaName string, db *sql.DB) ([]
 	dbs := []MaskingPolicyStruct{}
 	err = sqlx.StructScan(rows, &dbs)
 	if err == sql.ErrNoRows {
-		log.Printf("[DEBUG] no masking policies found")
+		log.Println("[DEBUG] no masking policies found")
 		return nil, nil
 	}
 	return dbs, errors.Wrapf(err, "unable to scan row for %s", stmt)

pkg/snowflake/materialized_view.go

@@ -227,7 +227,7 @@ func ListMaterializedViews(databaseName string, schemaName string, db *sql.DB) (
 	dbs := []materializedView{}
 	err = sqlx.StructScan(rows, &dbs)
 	if err == sql.ErrNoRows {
-		log.Printf("[DEBUG] no materialized views found")
+		log.Println("[DEBUG] no materialized views found")
 		return nil, nil
 	}
 	return dbs, pe.Wrapf(err, "unable to scan row for %s", stmt)

pkg/snowflake/pipe.go

@@ -68,13 +68,13 @@ func (pb *PipeBuilder) WithCopyStatement(s string) *PipeBuilder {
 	return pb
 }
 
-/// WithIntegration adds Integration specification to the PipeBuilder
+// / WithIntegration adds Integration specification to the PipeBuilder
 func (pb *PipeBuilder) WithIntegration(s string) *PipeBuilder {
 	pb.integration = s
 	return pb
 }
 
-/// WithErrorIntegration adds ErrorIntegration specification to the PipeBuilder
+// / WithErrorIntegration adds ErrorIntegration specification to the PipeBuilder
 func (pb *PipeBuilder) WithErrorIntegration(s string) *PipeBuilder {
 	pb.errorIntegration = s
 	return pb
@@ -190,7 +190,7 @@ func ListPipes(databaseName string, schemaName string, db *sql.DB) ([]pipe, erro
 	dbs := []pipe{}
 	err = sqlx.StructScan(rows, &dbs)
 	if err == sql.ErrNoRows {
-		log.Printf("[DEBUG] no pipes found")
+		log.Println("[DEBUG] no pipes found")
 		return nil, nil
 	}
 	return dbs, errors.Wrapf(err, "unable to scan row for %s", stmt)

pkg/snowflake/procedure.go

@@ -289,7 +289,7 @@ func ListProcedures(databaseName string, schemaName string, db *sql.DB) ([]proce
 	dbs := []procedure{}
 	err = sqlx.StructScan(rows, &dbs)
 	if err == sql.ErrNoRows {
-		log.Printf("[DEBUG] no procedures found")
+		log.Println("[DEBUG] no procedures found")
 		return nil, nil
 	}
 	return dbs, pe.Wrapf(err, "unable to scan row for %s", stmt)

pkg/snowflake/resource_monitor.go

@@ -163,7 +163,7 @@ func ListResourceMonitors(db *sql.DB) ([]resourceMonitor, error) {
 	dbs := []resourceMonitor{}
 	err = sqlx.StructScan(rows, &dbs)
 	if err == sql.ErrNoRows {
-		log.Printf("[DEBUG] no resouce monitors found")
+		log.Println("[DEBUG] no resouce monitors found")
 		return nil, nil
 	}
 	return dbs, errors.Wrapf(err, "unable to scan row for %s", stmt)

pkg/snowflake/row_access_policy.go

@@ -63,11 +63,10 @@ func (rapb *RowAccessPolicyBuilder) WithRowAccessExpression(rowAccessExpression
 //
 // Supported DDL operations are:
 //   - CREATE ROW ACCESS POLICY
-//	 - ALTER ROW ACCESS POLICY
+//   - ALTER ROW ACCESS POLICY
 //   - DROP ROW ACCESS POLICY
 //   - SHOW ROW ACCESS POLICIES
 //   - DESCRIBE ROW ACCESS POLICY
-//
 func RowAccessPolicy(name, db, schema string) *RowAccessPolicyBuilder {
 	return &RowAccessPolicyBuilder{
 		name:   name,
@@ -159,7 +158,7 @@ func ListRowAccessPolicies(databaseName string, schemaName string, db *sql.DB) (
 	dbs := []RowAccessPolicyStruct{}
 	err = sqlx.StructScan(rows, &dbs)
 	if err == sql.ErrNoRows {
-		log.Printf("[DEBUG] no row access policies found")
+		log.Println("[DEBUG] no row access policies found")
 		return nil, nil
 	}
 	return dbs, pe.Wrapf(err, "unable to scan row for %s", stmt)

pkg/snowflake/schema.go

@@ -229,7 +229,7 @@ func ListSchemas(databaseName string, db *sql.DB) ([]schema, error) {
 	dbs := []schema{}
 	err = sqlx.StructScan(rows, &dbs)
 	if err == sql.ErrNoRows {
-		log.Printf("[DEBUG] no schemas found")
+		log.Println("[DEBUG] no schemas found")
 		return nil, nil
 	}
 	return dbs, errors.Wrapf(err, "unable to scan row for %s", stmt)

pkg/snowflake/sequence.go

@@ -106,7 +106,7 @@ func ListSequences(databaseName string, schemaName string, db *sql.DB) ([]sequen
 	dbs := []sequence{}
 	err = sqlx.StructScan(rows, &dbs)
 	if err == sql.ErrNoRows {
-		log.Printf("[DEBUG] no sequences found")
+		log.Println("[DEBUG] no sequences found")
 		return nil, nil
 	}
 	return dbs, errors.Wrapf(err, "unable to scan row for %s", stmt)

pkg/snowflake/stage.go

@@ -323,7 +323,7 @@ func ListStages(databaseName string, schemaName string, db *sql.DB) ([]stage, er
 	dbs := []stage{}
 	err = sqlx.StructScan(rows, &dbs)
 	if err == sql.ErrNoRows {
-		log.Printf("[DEBUG] no stages found")
+		log.Println("[DEBUG] no stages found")
 		return nil, nil
 	}
 	return dbs, errors.Wrapf(err, "unable to scan row for %s", stmt)

pkg/snowflake/storage_integration.go

@@ -51,7 +51,7 @@ func ListStorageIntegrations(db *sql.DB) ([]storageIntegration, error) {
 	dbs := []storageIntegration{}
 	err = sqlx.StructScan(rows, &dbs)
 	if err == sql.ErrNoRows {
-		log.Printf("[DEBUG] no resouce monitors found")
+		log.Println("[DEBUG] no resouce monitors found")
 		return nil, nil
 	}
 	return dbs, errors.Wrapf(err, "unable to scan row for %s", stmt)

pkg/snowflake/stream.go

@@ -179,7 +179,7 @@ func ListStreams(databaseName string, schemaName string, db *sql.DB) ([]descStre
 	dbs := []descStreamRow{}
 	err = sqlx.StructScan(rows, &dbs)
 	if err == sql.ErrNoRows {
-		log.Printf("[DEBUG] no stages found")
+		log.Println("[DEBUG] no stages found")
 		return nil, nil
 	}
 	return dbs, errors.Wrapf(err, "unable to scan row for %s", stmt)

pkg/snowflake/table.go

@@ -381,7 +381,7 @@ func (tb *TableBuilder) UnsetTag(tag TagValue) string {
 	return fmt.Sprintf(`ALTER TABLE %s UNSET TAG "%v"."%v"."%v"`, tb.QualifiedName(), tag.Database, tag.Schema, tag.Name)
 }
 
-//Function to get clustering definition
+// Function to get clustering definition
 func (tb *TableBuilder) GetClusterKeyString() string {
 
 	return JoinStringList(tb.clusterBy[:], ", ")
@@ -442,7 +442,7 @@ func (tb *TableBuilder) getCreateStatementBody() string {
 	return q.String()
 }
 
-//function to take the literal snowflake cluster statement returned from SHOW TABLES and convert it to a list of keys.
+// function to take the literal snowflake cluster statement returned from SHOW TABLES and convert it to a list of keys.
 func ClusterStatementToList(clusterStatement string) []string {
 	if clusterStatement == "" {
 		return nil
@@ -758,7 +758,7 @@ func ListTables(databaseName string, schemaName string, db *sql.DB) ([]table, er
 	dbs := []table{}
 	err = sqlx.StructScan(rows, &dbs)
 	if err == sql.ErrNoRows {
-		log.Printf("[DEBUG] no tables found")
+		log.Println("[DEBUG] no tables found")
 		return nil, nil
 	}
 	return dbs, errors.Wrapf(err, "unable to scan row for %s", stmt)

pkg/snowflake/tag.go

@@ -225,7 +225,7 @@ func ListTags(databaseName, schemaName string, db *sql.DB) ([]tag, error) {
 	tags := []tag{}
 	err = sqlx.StructScan(rows, &tags)
 	if err == sql.ErrNoRows {
-		log.Printf("[DEBUG] no tags found")
+		log.Println("[DEBUG] no tags found")
 		return nil, nil
 	}
 	return tags, errors.Wrapf(err, "unable to scan row for %s", stmt)

pkg/snowflake/task.go

@@ -418,7 +418,7 @@ func ListTasks(databaseName string, schemaName string, db *sql.DB) ([]task, erro
 	dbs := []task{}
 	err = sqlx.StructScan(rows, &dbs)
 	if err == sql.ErrNoRows {
-		log.Printf("[DEBUG] no tasks found")
+		log.Println("[DEBUG] no tasks found")
 		return nil, nil
 	}
 	return dbs, errors.Wrapf(err, "unable to scan row for %s", stmt)

pkg/snowflake/user.go

@@ -112,7 +112,7 @@ func ListUsers(pattern string, db *sql.DB) ([]user, error) {
 	dbs := []user{}
 	err = sqlx.StructScan(rows, &dbs)
 	if err == sql.ErrNoRows {
-		log.Printf("[DEBUG] no users found")
+		log.Println("[DEBUG] no users found")
 		return nil, nil
 	}
 	return dbs, errors.Wrapf(err, "unable to scan row for %s", stmt)

pkg/snowflake/view.go

@@ -26,7 +26,7 @@ type ViewBuilder struct {
 // QualifiedName prepends the db and schema if set and escapes everything nicely
 func (vb *ViewBuilder) QualifiedName() (string, error) {
 	if vb.db == "" || vb.schema == "" {
-		return "", errors.New("Views must specify a database and a schema")
+		return "", errors.New("views must specify a database and a schema")
 	}
 
 	return fmt.Sprintf(`"%v"."%v"."%v"`, vb.db, vb.schema, vb.name), nil
@@ -235,7 +235,7 @@ func ListViews(databaseName string, schemaName string, db *sql.DB) ([]view, erro
 	dbs := []view{}
 	err = sqlx.StructScan(rows, &dbs)
 	if err == sql.ErrNoRows {
-		log.Printf("[DEBUG] no views found")
+		log.Println("[DEBUG] no views found")
 		return nil, nil
 	}
 	return dbs, pe.Wrapf(err, "unable to scan row for %s", stmt)