CsvDataConnection.cs 10 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316
  1. using System;
  2. using System.ComponentModel;
  3. using System.Collections.Generic;
  4. using System.Text;
  5. using System.Data;
  6. using System.Data.Common;
  7. using System.IO;
  8. using System.Net;
  9. using FastReport.Utils;
  10. using System.Globalization;
  11. using System.Collections;
  12. namespace FastReport.Data
  13. {
  14. /// <summary>
  15. /// Represents a connection to csv file-based database.
  16. /// </summary>
  17. /// <example>This example shows how to add a new connection to the report.
  18. /// <code>
  19. /// Report report1;
  20. /// CsvDataConnection conn = new CsvDataConnection();
  21. /// conn.CsvFile = @"c:\data.csv";
  22. /// report1.Dictionary.Connections.Add(conn);
  23. /// conn.CreateAllTables();
  24. /// </code>
  25. /// </example>
  26. public partial class CsvDataConnection : DataConnectionBase
  27. {
  28. #region Fields
  29. #endregion Fields
  30. #region Properties
  31. /// <summary>
  32. /// Gets or sets the path to .csv file.
  33. /// </summary>
  34. [Category("Data")]
  35. public string CsvFile
  36. {
  37. get
  38. {
  39. CsvConnectionStringBuilder builder = new CsvConnectionStringBuilder(ConnectionString);
  40. return builder.CsvFile;
  41. }
  42. set
  43. {
  44. CsvConnectionStringBuilder builder = new CsvConnectionStringBuilder(ConnectionString);
  45. builder.CsvFile = value;
  46. ConnectionString = CheckForChangeConnection(builder);
  47. }
  48. }
  49. /// <summary>
  50. /// Gets or sets the codepage of the .csv file.
  51. /// </summary>
  52. [Category("Data")]
  53. public int Codepage
  54. {
  55. get
  56. {
  57. CsvConnectionStringBuilder builder = new CsvConnectionStringBuilder(ConnectionString);
  58. return builder.Codepage;
  59. }
  60. set
  61. {
  62. CsvConnectionStringBuilder builder = new CsvConnectionStringBuilder(ConnectionString);
  63. builder.Codepage = value;
  64. ConnectionString = builder.ToString();
  65. }
  66. }
  67. /// <summary>
  68. /// Gets or sets the separator of the .csv file.
  69. /// </summary>
  70. [Category("Data")]
  71. public string Separator
  72. {
  73. get
  74. {
  75. CsvConnectionStringBuilder builder = new CsvConnectionStringBuilder(ConnectionString);
  76. return builder.Separator;
  77. }
  78. set
  79. {
  80. CsvConnectionStringBuilder builder = new CsvConnectionStringBuilder(ConnectionString);
  81. builder.Separator = value;
  82. ConnectionString = builder.ToString();
  83. }
  84. }
  85. /// <summary>
  86. /// Gets or sets the value indicating that field names should be loaded from the first string of the file.
  87. /// </summary>
  88. [Category("Data")]
  89. public bool FieldNamesInFirstString
  90. {
  91. get
  92. {
  93. CsvConnectionStringBuilder builder = new CsvConnectionStringBuilder(ConnectionString);
  94. return builder.FieldNamesInFirstString;
  95. }
  96. set
  97. {
  98. CsvConnectionStringBuilder builder = new CsvConnectionStringBuilder(ConnectionString);
  99. builder.FieldNamesInFirstString = value;
  100. ConnectionString = builder.ToString();
  101. }
  102. }
  103. /// <summary>
  104. /// Gets or sets the value indicating that quotation marks should be removed.
  105. /// </summary>
  106. [Category("Data")]
  107. public bool RemoveQuotationMarks
  108. {
  109. get
  110. {
  111. CsvConnectionStringBuilder builder = new CsvConnectionStringBuilder(ConnectionString);
  112. return builder.RemoveQuotationMarks;
  113. }
  114. set
  115. {
  116. CsvConnectionStringBuilder builder = new CsvConnectionStringBuilder(ConnectionString);
  117. builder.RemoveQuotationMarks = value;
  118. ConnectionString = builder.ToString();
  119. }
  120. }
  121. /// <summary>
  122. /// Gets or sets the value indicating that field types fhould be converted.
  123. /// </summary>
  124. [Category("Data")]
  125. public bool ConvertFieldTypes
  126. {
  127. get
  128. {
  129. CsvConnectionStringBuilder builder = new CsvConnectionStringBuilder(ConnectionString);
  130. return builder.ConvertFieldTypes;
  131. }
  132. set
  133. {
  134. CsvConnectionStringBuilder builder = new CsvConnectionStringBuilder(ConnectionString);
  135. builder.ConvertFieldTypes = value;
  136. ConnectionString = builder.ToString();
  137. }
  138. }
  139. /// <summary>
  140. /// Gets or sets locale name used to auto-convert numeric fields, e.g. "en-US".
  141. /// </summary>
  142. [Category("Data")]
  143. public string NumberFormat
  144. {
  145. get
  146. {
  147. CsvConnectionStringBuilder builder = new CsvConnectionStringBuilder(ConnectionString);
  148. return builder.NumberFormat;
  149. }
  150. set
  151. {
  152. CsvConnectionStringBuilder builder = new CsvConnectionStringBuilder(ConnectionString);
  153. builder.NumberFormat = value;
  154. ConnectionString = builder.ToString();
  155. }
  156. }
  157. /// <summary>
  158. /// Gets or sets locale name used to auto-convert currency fields, e.g. "en-US".
  159. /// </summary>
  160. [Category("Data")]
  161. public string CurrencyFormat
  162. {
  163. get
  164. {
  165. CsvConnectionStringBuilder builder = new CsvConnectionStringBuilder(ConnectionString);
  166. return builder.CurrencyFormat;
  167. }
  168. set
  169. {
  170. CsvConnectionStringBuilder builder = new CsvConnectionStringBuilder(ConnectionString);
  171. builder.CurrencyFormat = value;
  172. ConnectionString = builder.ToString();
  173. }
  174. }
  175. /// <summary>
  176. /// Gets or sets locale name used to auto-convert datetime fields, e.g. "en-US".
  177. /// </summary>
  178. [Category("Data")]
  179. public string DateTimeFormat
  180. {
  181. get
  182. {
  183. CsvConnectionStringBuilder builder = new CsvConnectionStringBuilder(ConnectionString);
  184. return builder.DateTimeFormat;
  185. }
  186. set
  187. {
  188. CsvConnectionStringBuilder builder = new CsvConnectionStringBuilder(ConnectionString);
  189. builder.DateTimeFormat = value;
  190. ConnectionString = builder.ToString();
  191. }
  192. }
  193. #endregion Properties
  194. #region Constructors
  195. /// <summary>
  196. /// Initializes a new instance of the <see cref="CsvDataConnection"/> class.
  197. /// </summary>
  198. public CsvDataConnection()
  199. {
  200. IsSqlBased = false;
  201. }
  202. #endregion Constructors
  203. #region Protected Methods
  204. /// <inheritdoc/>
  205. protected override DataSet CreateDataSet()
  206. {
  207. DataSet dataset = base.CreateDataSet();
  208. CsvConnectionStringBuilder builder = new CsvConnectionStringBuilder(ConnectionString);
  209. RelatedPathCheck(builder);
  210. List<string> rawLines = CsvUtils.ReadLines(builder);
  211. DataTable table = CsvUtils.CreateDataTable(builder, rawLines);
  212. if (table != null)
  213. dataset.Tables.Add(table);
  214. return dataset;
  215. }
  216. /// <summary>
  217. /// Checking a relative path relative to a file
  218. /// </summary>
  219. protected void RelatedPathCheck(CsvConnectionStringBuilder builder)
  220. {
  221. // checking for an empty file path string
  222. if (string.IsNullOrEmpty(builder.CsvFile))
  223. throw new Exception(Res.Get("ConnectionEditors,Common,OnlyUrlException"));
  224. if (Report == null || string.IsNullOrEmpty(Report.FileName))
  225. return;
  226. // combining a path will only work if the path is relative
  227. if (!File.Exists(builder.CsvFile))
  228. {
  229. Uri.TryCreate(builder.CsvFile, UriKind.RelativeOrAbsolute, out Uri uri);
  230. if (!uri.IsAbsoluteUri)
  231. if (!Path.GetDirectoryName(Report.FileName).Equals(Path.GetDirectoryName(builder.CsvFile)))
  232. builder.CsvFile = Path.Combine(Path.GetDirectoryName(Report.FileName), builder.CsvFile);
  233. }
  234. }
  235. /// <inheritdoc/>
  236. protected override void SetConnectionString(string value)
  237. {
  238. DisposeDataSet();
  239. base.SetConnectionString(value);
  240. }
  241. #endregion Protected Methods
  242. #region Public Methods
  243. /// <inheritdoc/>
  244. public override void FillTableSchema(DataTable table, string selectCommand, CommandParameterCollection parameters)
  245. {
  246. // do nothing
  247. }
  248. /// <inheritdoc/>
  249. public override void FillTableData(DataTable table, string selectCommand, CommandParameterCollection parameters)
  250. {
  251. // do nothing
  252. }
  253. /// <inheritdoc/>
  254. public override void CreateTable(TableDataSource source)
  255. {
  256. if (DataSet.Tables.Count == 1)
  257. {
  258. source.Table = DataSet.Tables[0];
  259. base.CreateTable(source);
  260. }
  261. else
  262. {
  263. source.Table = null;
  264. }
  265. }
  266. /// <inheritdoc/>
  267. public override void DeleteTable(TableDataSource source)
  268. {
  269. // do nothing
  270. }
  271. /// <inheritdoc/>
  272. public override string QuoteIdentifier(string value, DbConnection connection)
  273. {
  274. return value;
  275. }
  276. /// <inheritdoc/>
  277. public override string[] GetTableNames()
  278. {
  279. string[] result = new string[DataSet.Tables.Count];
  280. for (int i = 0; i < DataSet.Tables.Count; i++)
  281. {
  282. result[i] = DataSet.Tables[i].TableName;
  283. }
  284. return result;
  285. }
  286. #endregion Public Methods
  287. }
  288. }