crash.software
Projects
Pull Requests
Issues
Builds
dolt
Code
Files
Commits
Branches
Tags
Pull Requests
Code Comments
Code Compare
Issues
List
Boards
Milestones
Builds
Statistics
Contributions
Source Lines
Child Projects
Projects
STRLCPY
dolt
Files
🤬
Sign In
e87a8262
ROOT
/
go
/
libraries
/
doltcore
/
mvdata
/
engine_table_writer.go
Search
History
400 lines
|
ISO-8859-1
|
11 KB
Blame
Outline
2
4
8
No wrap
Soft wrap
Outline
tableWriterStatUpdateRate
SqlEngineTableWriter
se
:
*engine.SqlEngine
sqlCtx
:
*sql.Context
tableName
:
string
database
:
string
contOnErr
:
bool
force
:
bool
disableFks
:
bool
statsCB
:
noms.StatsCB
stats
:
types.AppliedEditStats
statOps
:
int32
importOption
:
TableImportOp
tableSchema
:
sql.PrimaryKeySchema
rowOperationSchema
:
sql.PrimaryKeySchema
NewSqlEngineTableWriter
(ctx context.Context, dEnv *env.DoltEnv, createTableSchema, rowOperationSchema schema.Schema, options *MoverOptions, statsCB noms.StatsCB)
:
(*SqlEngineTableWriter, error)
NewSqlEngineTableWriterWithEngine
(ctx *sql.Context, eng *sqle.Engine, db dsqle.Database, createTableSchema, rowOperationSchema schema.Schema, options *MoverOptions, statsCB noms.StatsCB)
:
(*SqlEngineTableWriter, error)
generateOnDuplicateKeyExpressions
(sch sql.Schema)
:
[]sql.Expression
*SqlEngineTableWriter
WriteRows
(ctx context.Context, inputChannel chan sql.Row, badRowCb func(row sql.Row, err error) bool)
:
(err error)
Commit
(ctx context.Context)
:
error
RowOperationSchema
()
:
sql.PrimaryKeySchema
TableSchema
()
:
sql.PrimaryKeySchema
forceDropTableIfNeeded
()
:
error
createOrEmptyTableIfNeeded
()
:
error
createTable
()
:
error
getInsertNode
(inputChannel chan sql.Row)
:
(sql.Node, error)
createInsertImportNode
(source chan sql.Row, ignore bool, replace bool, onDuplicateExpression []sql.Expression)
:
(sql.Node, error)
All occurrences
Please wait...
Page is in error, reload to recover