service

Documentation

Index

• func CreateFile(f string) (*os.File, error)
• func ExportFromFolderToFolder(oracle_uri string, fromFolderPath string, toFolderPath string) error
• func ExportOracleQuery(oracle_uri string, sqlFilePath string, destTableName string, ...) error
• func FSCreateDirectory(p string) error
• func FSExists(path string) (bool, error)
• func FSGetDirectories(p string) (*[]string, error)
• func FSRemove(path string) error
• func FSWorkOnDirectoryInPath(p string, workFunc DirWorkFunc) error
• func FSWorkOnItemInPath(p string, workFunc DirWorkFunc) error
• func LoadFromJSONFile(f string, i interface{}) error
• func Map(vs []string, f func(string) string) []string
• func ReadCSV(rc io.Reader) (ch chan []string)
• func RunCSVExport(uri string, table string, extractColumn []string, rowLimit int, file string) error
• type DirWorkFunc

Functions

func CreateFile

func CreateFile(f string) (*os.File, error)

func ExportFromFolderToFolder

func ExportFromFolderToFolder(
	oracle_uri string,
	fromFolderPath string,
	toFolderPath string,
) error

ExportFromFolderToFolder ...

func ExportOracleQuery

func ExportOracleQuery(
	oracle_uri string,
	sqlFilePath string,
	destTableName string,
	destinationFilePath string,
) error

ExportOracleQuery ...

func FSCreateDirectory

func FSCreateDirectory(p string) error

FSCreateDirectory ...

func FSExists

func FSExists(path string) (bool, error)

FSExists ...

func FSGetDirectories

func FSGetDirectories(p string) (*[]string, error)

FSGetDirectories ...

func FSRemove

func FSRemove(path string) error

FSRemove ...

func FSWorkOnDirectoryInPath

func FSWorkOnDirectoryInPath(p string, workFunc DirWorkFunc) error

FSWorkOnDirectoryInPath ...

func FSWorkOnItemInPath

func FSWorkOnItemInPath(p string, workFunc DirWorkFunc) error

FSWorkOnItemInPath ...

func LoadFromJSONFile

func LoadFromJSONFile(f string, i interface{}) error

LoadFromJSONFile ...

func Map

func Map(vs []string, f func(string) string) []string

func ReadCSV

func ReadCSV(rc io.Reader) (ch chan []string)

ReadCSV read csv per line and send current one into channel

func RunCSVExport

func RunCSVExport(uri string, table string, extractColumn []string, rowLimit int, file string) error

RunCSVExport ...

Types

type DirWorkFunc

type DirWorkFunc func(path os.FileInfo) error

DirWorkFunc ...