Safe Haskell	None
Language	GHC2021

Napkin.Run.BigQuery

Contents

Orphan instances

Documentation

newtype BigQueryRunError #

Constructors

ProtoErrors (NonEmpty ErrorProto)

Instances

Instances details

Exception BigQueryRunError #
Instance details Defined in Napkin.Run.BigQuery.Types Methods toException :: BigQueryRunError -> SomeException # fromException :: SomeException -> Maybe BigQueryRunError # displayException :: BigQueryRunError -> String #
Show BigQueryRunError #
Instance details Defined in Napkin.Run.BigQuery.Types Methods showsPrec :: Int -> BigQueryRunError -> ShowS # show :: BigQueryRunError -> String # showList :: [BigQueryRunError] -> ShowS #
Eq BigQueryRunError #
Instance details Defined in Napkin.Run.BigQuery.Types Methods (==) :: BigQueryRunError -> BigQueryRunError -> Bool # (/=) :: BigQueryRunError -> BigQueryRunError -> Bool #

data family BackendConn b #

Instances

Instances details

Generic (BackendConn Postgres) #

Instance details

Defined in Napkin.Run.Postgres

Associated Types

type Rep (BackendConn Postgres)

Instance details

Defined in Napkin.Run.Postgres

type Rep (BackendConn Postgres) = D1 ('MetaData "BackendConn" "Napkin.Run.Postgres" "napkin-1.0.0-5YkWAC9Wc776PT0LDghaFb" 'False) (C1 ('MetaCons "PostgresConn" 'PrefixI 'True) (S1 ('MetaSel ('Just "getConnectionString") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 ConnectionString) :*: S1 ('MetaSel ('Just "getPostgresConn") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Pool Connection))))

Methods

from :: BackendConn Postgres -> Rep (BackendConn Postgres) x #

to :: Rep (BackendConn Postgres) x -> BackendConn Postgres #

data BackendConn BigQuery #

Instance details

Defined in Napkin.Run.BigQuery

data BackendConn BigQuery = BigQueryEnv {

}

data BackendConn MsSql #

Instance details

Defined in Napkin.Run.MsSql

data BackendConn MsSql = MsSqlConn {

connectionString :: ConnectionString
msSqlConn :: Pool Connection

}

data BackendConn Postgres #

Instance details

Defined in Napkin.Run.Postgres

data BackendConn Postgres = PostgresConn {

}

data BackendConn Redshift #

Instance details

Defined in Napkin.Run.Redshift

data BackendConn Redshift = RedshiftConn ConnectionString (Pool Connection)

data BackendConn Sqlite #

Instance details

Defined in Napkin.Run.Sqlite

data BackendConn Sqlite = SqliteConn {

connectionString :: ConnectionString
sqliteConn :: Pool Connection

}

type Rep (BackendConn Postgres) #

Instance details

Defined in Napkin.Run.Postgres

type Rep (BackendConn Postgres) = D1 ('MetaData "BackendConn" "Napkin.Run.Postgres" "napkin-1.0.0-5YkWAC9Wc776PT0LDghaFb" 'False) (C1 ('MetaCons "PostgresConn" 'PrefixI 'True) (S1 ('MetaSel ('Just "getConnectionString") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 ConnectionString) :*: S1 ('MetaSel ('Just "getPostgresConn") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Pool Connection))))

data family BackendSchemaField (bk :: k) #

Instances

Instances details

Command GetRelationSchema [BackendSchemaField BigQuery] BigQuery #
Instance details Defined in Napkin.Run.BigQuery Methods execCommand :: MonadNapkin BigQuery m => BackendConn BigQuery -> GetRelationSchema -> m [BackendSchemaField BigQuery] #
Command GetRelationSchema [BackendSchemaField MsSql] MsSql #
Instance details Defined in Napkin.Run.MsSql Methods execCommand :: MonadNapkin MsSql m => BackendConn MsSql -> GetRelationSchema -> m [BackendSchemaField MsSql] #
Command GetRelationSchema [BackendSchemaField Postgres] Postgres #
Instance details Defined in Napkin.Run.Postgres Methods execCommand :: MonadNapkin Postgres m => BackendConn Postgres -> GetRelationSchema -> m [BackendSchemaField Postgres] #
Command GetRelationSchema [BackendSchemaField Redshift] Redshift #
Instance details Defined in Napkin.Run.Redshift Methods execCommand :: MonadNapkin Redshift m => BackendConn Redshift -> GetRelationSchema -> m [BackendSchemaField Redshift] #
Command GetRelationSchema [BackendSchemaField Sqlite] Sqlite #
Instance details Defined in Napkin.Run.Sqlite Methods execCommand :: MonadNapkin Sqlite m => BackendConn Sqlite -> GetRelationSchema -> m [BackendSchemaField Sqlite] #
Show (BackendSchemaField BigQuery) #
Instance details Defined in Napkin.Run.BigQuery Methods showsPrec :: Int -> BackendSchemaField BigQuery -> ShowS # show :: BackendSchemaField BigQuery -> String # showList :: [BackendSchemaField BigQuery] -> ShowS #
Show (BackendSchemaField MsSql) #
Instance details Defined in Napkin.Run.MsSql Methods showsPrec :: Int -> BackendSchemaField MsSql -> ShowS # show :: BackendSchemaField MsSql -> String # showList :: [BackendSchemaField MsSql] -> ShowS #
Show (BackendSchemaField Postgres) #
Instance details Defined in Napkin.Run.Postgres Methods showsPrec :: Int -> BackendSchemaField Postgres -> ShowS # show :: BackendSchemaField Postgres -> String # showList :: [BackendSchemaField Postgres] -> ShowS #
Show (BackendSchemaField Redshift) #
Instance details Defined in Napkin.Run.Redshift Methods showsPrec :: Int -> BackendSchemaField Redshift -> ShowS # show :: BackendSchemaField Redshift -> String # showList :: [BackendSchemaField Redshift] -> ShowS #
Show (BackendSchemaField Sqlite) #
Instance details Defined in Napkin.Run.Sqlite Methods showsPrec :: Int -> BackendSchemaField Sqlite -> ShowS # show :: BackendSchemaField Sqlite -> String # showList :: [BackendSchemaField Sqlite] -> ShowS #
Eq (BackendSchemaField BigQuery) #
Instance details Defined in Napkin.Run.BigQuery Methods (==) :: BackendSchemaField BigQuery -> BackendSchemaField BigQuery -> Bool # (/=) :: BackendSchemaField BigQuery -> BackendSchemaField BigQuery -> Bool #
Eq (BackendSchemaField MsSql) #
Instance details Defined in Napkin.Run.MsSql Methods (==) :: BackendSchemaField MsSql -> BackendSchemaField MsSql -> Bool # (/=) :: BackendSchemaField MsSql -> BackendSchemaField MsSql -> Bool #
Eq (BackendSchemaField Postgres) #
Instance details Defined in Napkin.Run.Postgres Methods (==) :: BackendSchemaField Postgres -> BackendSchemaField Postgres -> Bool # (/=) :: BackendSchemaField Postgres -> BackendSchemaField Postgres -> Bool #
Eq (BackendSchemaField Redshift) #
Instance details Defined in Napkin.Run.Redshift Methods (==) :: BackendSchemaField Redshift -> BackendSchemaField Redshift -> Bool # (/=) :: BackendSchemaField Redshift -> BackendSchemaField Redshift -> Bool #
Eq (BackendSchemaField Sqlite) #
Instance details Defined in Napkin.Run.Sqlite Methods (==) :: BackendSchemaField Sqlite -> BackendSchemaField Sqlite -> Bool # (/=) :: BackendSchemaField Sqlite -> BackendSchemaField Sqlite -> Bool #
FromRow (BackendSchemaField Sqlite) #
Instance details Defined in Napkin.Run.Sqlite Methods fromRow :: RowParser (BackendSchemaField Sqlite) #
data BackendSchemaField BigQuery #
Instance details Defined in Napkin.Run.BigQuery data BackendSchemaField BigQuery = BigQuerySchemaField TableFieldSchema
data BackendSchemaField MsSql #
Instance details Defined in Napkin.Run.MsSql data BackendSchemaField MsSql = MsSqlSchemaField MsSchemaField
data BackendSchemaField Postgres #
Instance details Defined in Napkin.Run.Postgres data BackendSchemaField Postgres = PostgresSchemaField PGSchemaField
data BackendSchemaField Redshift #
Instance details Defined in Napkin.Run.Redshift data BackendSchemaField Redshift = RedshiftSchemaField PGSchemaField
data BackendSchemaField Sqlite #
Instance details Defined in Napkin.Run.Sqlite data BackendSchemaField Sqlite = SqliteSchemaField { scdCid :: Int scdName :: Text scdType :: Text scdNullable :: Int scdDefaultValue :: Maybe Int scdPrimaryKey :: Int }

mkBigQueryEnvWithCredentials :: (MonadCatch m, Katip m) => Maybe Text -> Credentials BigQueryScopes -> DbBackendOptions BigQuery -> BQProjectId -> m (BackendConn BigQuery) #

mkBigQueryEnvWithJsonCredentials :: (MonadCatch m, Katip m) => Maybe Text -> CredentialsJson -> DbBackendOptions BigQuery -> BQProjectId -> m (BackendConn BigQuery) #

mkBigQueryEnvWithCredentialsFile :: (MonadCatch m, Katip m) => FilePath -> DbBackendOptions BigQuery -> BQProjectId -> m (BackendConn BigQuery) #

bqValidator :: (SpecDependency -> Ref Table) -> SpecsDeps -> [Text] #

parseBigQueryURI :: Text -> Maybe BigQueryURI #

data BigQueryURI #

Constructors

BigQueryURI
Fields _bquHost :: Text _bquProjectId :: BQProjectId

calcCost :: MonadNapkin BigQuery m => Job -> m Job #

executePoll :: Katip m => GoogleEnv -> BigQueryJobsInsert -> BQProjectId -> m Job #

jobInsert :: BQProjectId -> JobConfiguration -> BigQueryJobsInsert #

jobConfiguration :: Labels -> JobConfiguration #

jobConfigurationQuery :: Text -> JobConfigurationQuery #

Orphan instances

Backend BigQuery #

Instance details

Associated Types

data BackendConn BigQuery
Instance details Defined in Napkin.Run.BigQuery data BackendConn BigQuery = BigQueryEnv { bqeEnv :: Pool GoogleEnv bqeDefaultProject :: BQProjectId bqeJobLabels :: Labels }

Methods

backendQuery :: (MonadNapkin BigQuery m, RenderSql q BigQuery) => BackendConn BigQuery -> q -> m [Map Text Value] #

backendConnectionString :: BackendConn BigQuery -> ConnectionString #

RunBackendConn BigQuery #

Instance details

Methods

runBackendConn :: LogEnv -> DbBackendOptions BigQuery -> ConnectionString -> AppName -> Maybe CredentialsPath -> SpecFile -> Maybe AuthPort -> (Pipeline -> BackendConn BigQuery -> IO a) -> IO a #

HasBackendSchemaField BigQuery #

Instance details

Associated Types

data BackendSchemaField BigQuery
Instance details Defined in Napkin.Run.BigQuery data BackendSchemaField BigQuery = BigQuerySchemaField TableFieldSchema

Methods

fieldName :: BackendSchemaField BigQuery -> Text #

fieldType :: BackendSchemaField BigQuery -> Type #

CSVImport BigQuery #

Instance details

Methods

chunkLimit :: Int #

isEnabled :: Bool #

HasBackendQueryStats BigQuery #

Instance details

Associated Types

data BackendQueryStats BigQuery
Instance details Defined in Napkin.Run.BigQuery data BackendQueryStats BigQuery = BackendQueryStats { bytesAffected :: !(Maybe Int64) }

Methods

prettyPrint :: BackendQueryStats BigQuery -> Maybe String #

Command AEDA TableDiagnostics BigQuery #

Instance details

Methods

execCommand :: MonadNapkin BigQuery m => BackendConn BigQuery -> AEDA -> m TableDiagnostics #

Command AnnotateCommand () BigQuery #

Instance details

Methods

execCommand :: MonadNapkin BigQuery m => BackendConn BigQuery -> AnnotateCommand -> m () #

Command CheckTableExists Bool BigQuery #

Instance details

Methods

execCommand :: MonadNapkin BigQuery m => BackendConn BigQuery -> CheckTableExists -> m Bool #

Command CopyTable () BigQuery #

Instance details

Methods

execCommand :: MonadNapkin BigQuery m => BackendConn BigQuery -> CopyTable -> m () #

Command DeleteFrom () BigQuery #

Instance details

Methods

execCommand :: MonadNapkin BigQuery m => BackendConn BigQuery -> DeleteFrom -> m () #

Command DropTable () BigQuery #

Instance details

Methods

execCommand :: MonadNapkin BigQuery m => BackendConn BigQuery -> DropTable -> m () #

Command DropView () BigQuery #

Instance details

Methods

execCommand :: MonadNapkin BigQuery m => BackendConn BigQuery -> DropView -> m () #

Command GetTableKind TableKind BigQuery #

Instance details

Methods

execCommand :: MonadNapkin BigQuery m => BackendConn BigQuery -> GetTableKind -> m TableKind #

Command InsertIntoQuery () BigQuery #

Instance details

Methods

execCommand :: MonadNapkin BigQuery m => BackendConn BigQuery -> InsertIntoQuery -> m () #

Command InsertIntoTable () BigQuery #

Instance details

Methods

execCommand :: MonadNapkin BigQuery m => BackendConn BigQuery -> InsertIntoTable -> m () #

Command ReadAnnotationCommand TableAnnotations BigQuery #

Instance details

Methods

execCommand :: MonadNapkin BigQuery m => BackendConn BigQuery -> ReadAnnotationCommand -> m TableAnnotations #

Command RenameTable () BigQuery #

BQ implements rename via copy-then-drop

Instance details

Methods

execCommand :: MonadNapkin BigQuery m => BackendConn BigQuery -> RenameTable -> m () #

Command Grant () BigQuery #

Instance details

Methods

execCommand :: MonadNapkin BigQuery m => BackendConn BigQuery -> Grant -> m () #

Command UpdateQuery () BigQuery #

Instance details

Methods

execCommand :: MonadNapkin BigQuery m => BackendConn BigQuery -> UpdateQuery -> m () #

Command GetRelationSchema [BackendSchemaField BigQuery] BigQuery #

Instance details

Methods

execCommand :: MonadNapkin BigQuery m => BackendConn BigQuery -> GetRelationSchema -> m [BackendSchemaField BigQuery] #

Command ListTables (Set ListedTable) BigQuery #

Instance details

Methods

execCommand :: MonadNapkin BigQuery m => BackendConn BigQuery -> ListTables -> m (Set ListedTable) #

Command NormalizeTableNames (Map (Ref Table) NormalizedTable) BigQuery #

Instance details

Methods

execCommand :: MonadNapkin BigQuery m => BackendConn BigQuery -> NormalizeTableNames -> m (Map (Ref Table) NormalizedTable) #

Command (CreateMaterializedView MaterializedViewMeta) () BigQuery #

Instance details

Methods

execCommand :: MonadNapkin BigQuery m => BackendConn BigQuery -> CreateMaterializedView MaterializedViewMeta -> m () #

Command (CreateTable TableMeta) () BigQuery #

Instance details

Methods

execCommand :: MonadNapkin BigQuery m => BackendConn BigQuery -> CreateTable TableMeta -> m () #

Command (CreateTable ()) () BigQuery #

Instance details

Methods

execCommand :: MonadNapkin BigQuery m => BackendConn BigQuery -> CreateTable () -> m () #

Command (CreateTableDDL TableMeta) () BigQuery #

Instance details

Methods

execCommand :: MonadNapkin BigQuery m => BackendConn BigQuery -> CreateTableDDL TableMeta -> m () #

Command (CreateView ViewMeta) () BigQuery #

Instance details

Methods

execCommand :: MonadNapkin BigQuery m => BackendConn BigQuery -> CreateView ViewMeta -> m () #

FromJSON (BackendQueryStats BigQuery) #

Instance details

Methods

parseJSON :: Value -> Parser (BackendQueryStats BigQuery) #

parseJSONList :: Value -> Parser [BackendQueryStats BigQuery] #

omittedField :: Maybe (BackendQueryStats BigQuery) #

ToJSON (BackendQueryStats BigQuery) #

Instance details

Methods

toJSON :: BackendQueryStats BigQuery -> Value #

toEncoding :: BackendQueryStats BigQuery -> Encoding #

toJSONList :: [BackendQueryStats BigQuery] -> Value #

toEncodingList :: [BackendQueryStats BigQuery] -> Encoding #

omitField :: BackendQueryStats BigQuery -> Bool #

Monoid (BackendQueryStats BigQuery) #

Instance details

Methods

mempty :: BackendQueryStats BigQuery #

mappend :: BackendQueryStats BigQuery -> BackendQueryStats BigQuery -> BackendQueryStats BigQuery #

mconcat :: [BackendQueryStats BigQuery] -> BackendQueryStats BigQuery #

Semigroup (BackendQueryStats BigQuery) #

Instance details

Methods

(<>) :: BackendQueryStats BigQuery -> BackendQueryStats BigQuery -> BackendQueryStats BigQuery #

sconcat :: NonEmpty (BackendQueryStats BigQuery) -> BackendQueryStats BigQuery #

stimes :: Integral b => b -> BackendQueryStats BigQuery -> BackendQueryStats BigQuery #

Show (BackendSchemaField BigQuery) #

Instance details

Methods

showsPrec :: Int -> BackendSchemaField BigQuery -> ShowS #

show :: BackendSchemaField BigQuery -> String #

showList :: [BackendSchemaField BigQuery] -> ShowS #

Show (BackendQueryStats BigQuery) #

Instance details

Methods

showsPrec :: Int -> BackendQueryStats BigQuery -> ShowS #

show :: BackendQueryStats BigQuery -> String #

showList :: [BackendQueryStats BigQuery] -> ShowS #

Eq (BackendSchemaField BigQuery) #

Instance details

Methods

(==) :: BackendSchemaField BigQuery -> BackendSchemaField BigQuery -> Bool #

(/=) :: BackendSchemaField BigQuery -> BackendSchemaField BigQuery -> Bool #

Eq (BackendQueryStats BigQuery) #

Instance details

Methods

(==) :: BackendQueryStats BigQuery -> BackendQueryStats BigQuery -> Bool #

(/=) :: BackendQueryStats BigQuery -> BackendQueryStats BigQuery -> Bool #

Key	Shortcut
s	Open this search box
esc	Close this search box
↓,ctrl + j	Move down in search results
↑,ctrl + k	Move up in search results
↵	Go to active search result