exportSQLWithContext exports SQL INSERT statements with proper context.
( ctx context.Context, w io.Writer, stores *store.Store, instance *store.InstanceMessage, database *store.DatabaseMessage, result *v1pb.QueryResult, request *v1pb.ExportRequest, )
| 1315 | |
| 1316 | // exportSQLWithContext exports SQL INSERT statements with proper context. |
| 1317 | func exportSQLWithContext( |
| 1318 | ctx context.Context, |
| 1319 | w io.Writer, |
| 1320 | stores *store.Store, |
| 1321 | instance *store.InstanceMessage, |
| 1322 | database *store.DatabaseMessage, |
| 1323 | result *v1pb.QueryResult, |
| 1324 | request *v1pb.ExportRequest, |
| 1325 | ) error { |
| 1326 | resourceList, err := export.GetResources( |
| 1327 | ctx, |
| 1328 | stores, |
| 1329 | instance.Metadata.GetEngine(), |
| 1330 | database.DatabaseName, |
| 1331 | request.Statement, |
| 1332 | instance, |
| 1333 | parsercontext.BuildGetDatabaseMetadataFunc(stores), |
| 1334 | parsercontext.BuildListDatabaseNamesFunc(stores), |
| 1335 | parsercontext.BuildGetLinkedDatabaseMetadataFunc(stores, instance.Metadata.GetEngine()), |
| 1336 | ) |
| 1337 | if err != nil { |
| 1338 | return errors.Wrapf(err, "failed to extract resource list") |
| 1339 | } |
| 1340 | statementPrefix, err := export.SQLStatementPrefix(instance.Metadata.GetEngine(), resourceList, result.ColumnNames) |
| 1341 | if err != nil { |
| 1342 | return err |
| 1343 | } |
| 1344 | return export.SQLToWriter(w, instance.Metadata.GetEngine(), statementPrefix, result) |
| 1345 | } |
| 1346 | |
| 1347 | type encryptContent struct { |
| 1348 | Name string |
no test coverage detected