Method createTable

plugins/destination/mssql/client/tables.go:11–25

(ctx context.Context, table *schema.Table)

)

func (c *Client) createTable(ctx context.Context, table *schema.Table) (err error) {
	c.logger.Debug().Str("table", table.Name).Msg("Table doesn't exist, creating")
	defer func() {
		if err != nil {
			c.logErr(err)
		}
	}()

	_, err = c.db.ExecContext(ctx, queries.CreateTable(c.spec.Schema, table))
	if err != nil {
		return fmt.Errorf("failed to create table %s: %w", table.Name, err)
	}

	return c.ensureTVP(ctx, table)
}

func (c *Client) dropTable(ctx context.Context, table *schema.Table) (err error) {
	c.logger.Debug().Str("table", table.Name).Msg("Table exists, dropping")