OscarImportHandler¶

批量插入帮助类,实现表数据批量插入操作.

public sealed class OscarImportHandler : IDisposable

构造函数¶

// 创建 OscarImportHandler 实例
// 参数: Connection -> 连接实例
// 参数: TableOid ->
public OscarImportHandler(OscarConnection Connection, long TableOid);

// 创建 OscarImportHandler 实例
// 参数: Connection -> 连接实例
// 参数: TableName -> 表名
public OscarImportHandler(OscarConnection Connection, string TableName);

// 创建 OscarImportHandler 实例
// 参数: Connection -> 连接实例
// 参数: SchemaName -> 模式名
// 参数: TableName -> 表名
public OscarImportHandler(OscarConnection Connection, string SchemaName, string TableName);

属性¶

public bool IsByte { set; }
public bool IsNull { get; set; }

// 获取连接实例
public OscarConnection Connection { get; }

方法¶

public void AddRow(object[] fields);
public void Dispose();
public void EndRow();
public int ExecuteImport(string filePath, string columnSep, string rowSep, char esc);
public int ExecuteImport(string filePath, string columnSep, string rowSep);
public int ExecuteImport(OscarConnection conn);
public int ExecuteImport();
public void ExportCSVData(string path, string columnSep, string rowSep, char escape);
public void ExportData(string path, string columnSep, string rowSep);
public void ExportData(string path);
public void SetBigInt(int ColumnIndex, long? x);
public void SetBool(int ColumnIndex, bool? x);
public void SetByteArray(int ColumnIndex, byte[] x);
public void SetByteArray(int ColumnIndex, byte[] x, int length);
public void SetChar(int ColumnIndex, char? x);
public void SetDateTime(int ColumnIndex, DateTime? x);
public void SetDBNull(int ColumnIndex);
public void SetDecimal(int ColumnIndex, decimal? x);
public void SetDouble(int ColumnIndex, double? x);
public void SetFloat(int ColumnIndex, float? x);
public void setHintParam(string hintParams);
public void SetImportOrder(string[] columnNames);
public void SetInt(int ColumnIndex, int? x);
public void SetLob(int ColumnIndex, string x);
public void SetLob(int ColumnIndex, Stream x);
public void SetLob(int ColumnIndex, Stream x, long length);
public void SetLob(int ColumnIndex, byte[] x);
public void SetObject(int ColumnIndex, object x);
public void SetSByte(int ColumnIndex, sbyte? x);
public void SetSmallInt(int ColumnIndex, short? x);
public void SetString(int ColumnIndex, string x);