Столбцы GetSchemaTable отсутствуют? - PullRequest
Новая
       15

Столбцы GetSchemaTable отсутствуют?

0 голосов
/ 30 сентября 2011

Я использую этот код для передачи данных из dataReader в DataTable, который затем можно сериализовать.

Однако, похоже, что любой столбец с нулевым значением не записывается в xml.

Я не вижу проблемы.

Это весь мой класс, и я вызываю этот метод 

Process(IDataReader data, string filePath)

Я уверен, что это работает, потому что я использовал его для сериализации dataTables до

Process(DataTable table, string filePath)

Так что я думаю, что это должно быть в методе "GetDataTableFromSqlDataReader" ?? 

public class DataSerialisation
{
    public static DataRow GetFirstDataRow(string xmlFilePath)
    {
        return GetDataTable(xmlFilePath).Rows[0];
    }

    public static DataTable GetDataTable(string xmlFilePath)
    {
        DataSet ds = new DataSet();
        ds.ReadXml(xmlFilePath);
        return ds.Tables[0];
    }

    private static DataTable GetDataTableFromSqlDataReader(IDataReader dr)
    {

        DataTable dtSchema = dr.GetSchemaTable();
        DataTable dt = new DataTable();
        ArrayList listCols = new ArrayList();
        if (dtSchema != null)
        {
            foreach (DataRow drow in dtSchema.Rows)
            {
                string columnName = Convert.ToString(drow["columnName"]); //drow["columnName"].ToString();

                DataColumn column = new DataColumn(columnName, (Type) (drow["DataType"]));
                //column.ColumnName = columnName;
                //column.Unique = (bool) (drow["IsUnique"]);
                column.AllowDBNull = (bool) (drow["AllowDBNull"]);
                //column.AutoIncrement = (bool) (drow["IsAutoIncrement"]);
                //column.AutoIncrement = (bool) (drow["IsAutoIncrement"]);

                listCols.Add(column);
                dt.Columns.Add(column);
            }
            while (dr.Read())
            {
                DataRow dataRow = dt.NewRow();
                for (int i = 0; i < listCols.Count; i++)
                    dataRow[((DataColumn) listCols[i])] = dr[i];

                dt.Rows.Add(dataRow);
            }
        }
        return dt;
    }

    public static void Process(IDataReader data, string filePath)
    {
        Process(GetDataTableFromSqlDataReader(data), filePath);
    }

    public static void Process(DataTable table, string filePath)
    {
        DataSet ds = new DataSet();

        ds.Tables.Add(table.Clone());

        foreach (DataRow row in table.Rows)
        {
            DataRow newRow = ds.Tables[0].NewRow();
            for (int col = 0; col < ds.Tables[0].Columns.Count; col++)
                newRow[col] = row[col];
            ds.Tables[0].Rows.Add(newRow);
        }
        ds.WriteXml(new StreamWriter(filePath));
    }
}
...