File tree Expand file tree Collapse file tree 2 files changed +24
-0
lines changed
docs/content/api/MySqlConnector Expand file tree Collapse file tree 2 files changed +24
-0
lines changed Original file line number Diff line number Diff line change @@ -17,11 +17,23 @@ Example code:
1717// https://dev.mysql.com/doc/refman/8.0/en/insert-select.html
1818var dataTable = GetDataTableFromExternalSource ();
1919
20+ // open the connection
2021using var connection = new MySqlConnection (" ...;AllowLoadLocalInfile=True" );
2122await connection .OpenAsync ();
23+
24+ // attach an event handler to retrieve warnings/errors
25+ IReadOnlyList < MySqlError > errors = Array .Empty <MySqlError >();
26+ void InfoMessageHandler (object sender , MySqlInfoMessageEventArgs args ) => errors = args .Errors ;
27+ connection .InfoMessage += InfoMessageHandler ;
28+
29+ // bulk copy the data
2230var bulkCopy = new MySqlBulkCopy (connection );
2331bulkCopy .DestinationTableName = " some_table_name" ;
2432await bulkCopy .WriteToServerAsync (dataTable );
33+
34+ // check for errors
35+ connection .InfoMessage -= InfoMessageHandler ;
36+ if (errors .Count != 0 ) { /* handle errors */ }
2537```
2638
2739``` csharp
Original file line number Diff line number Diff line change @@ -29,11 +29,23 @@ namespace MySqlConnector
2929 /// // https://dev.mysql.com/doc/refman/8.0/en/insert-select.html
3030 /// var dataTable = GetDataTableFromExternalSource();
3131 ///
32+ /// // open the connection
3233 /// using var connection = new MySqlConnection("...;AllowLoadLocalInfile=True");
3334 /// await connection.OpenAsync();
35+ ///
36+ /// // attach an event handler to retrieve warnings/errors
37+ /// IReadOnlyList<MySqlError> errors = Array.Empty<MySqlError>();
38+ /// void InfoMessageHandler(object sender, MySqlInfoMessageEventArgs args) => errors = args.Errors;
39+ /// connection.InfoMessage += InfoMessageHandler;
40+ ///
41+ /// // bulk copy the data
3442 /// var bulkCopy = new MySqlBulkCopy(connection);
3543 /// bulkCopy.DestinationTableName = "some_table_name";
3644 /// await bulkCopy.WriteToServerAsync(dataTable);
45+ ///
46+ /// // check for errors
47+ /// connection.InfoMessage -= InfoMessageHandler;
48+ /// if (errors.Count != 0) { /* handle errors */ }
3749 /// </code>
3850 /// </summary>
3951 /// <remarks><para><strong>Note:</strong> This API is a unique feature of MySqlConnector; you must
You can’t perform that action at this time.
0 commit comments