JSONSerializer.cs 9.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480
  1. using System;
  2. using System.Collections;
  3. using System.Collections.Generic;
  4. using System.Data;
  5. using System.Globalization;
  6. using System.IO;
  7. using System.Text;
  8. internal class JSONSerializer
  9. {
  10. private readonly StringBuilder _output = new StringBuilder();
  11. private readonly int _MAX_DEPTH = 10;
  12. private int _current_depth = 0;
  13. private Dictionary<string, int> _globalTypes = new Dictionary<string, int>();
  14. private JSONParameters _params;
  15. private bool _TypesWritten = false;
  16. internal JSONSerializer(JSONParameters param)
  17. {
  18. _params = param;
  19. }
  20. internal string ConvertToJSON(object obj)
  21. {
  22. WriteValue(obj);
  23. string str = "";
  24. if (_params.UsingGlobalTypes)
  25. {
  26. StringBuilder sb = new StringBuilder();
  27. sb.Append("\"$types\":{");
  28. bool pendingSeparator = false;
  29. foreach (KeyValuePair<string, int> kv in _globalTypes)
  30. {
  31. if (pendingSeparator)
  32. {
  33. sb.Append(',');
  34. }
  35. pendingSeparator = true;
  36. sb.Append("\"");
  37. sb.Append(kv.Key);
  38. sb.Append("\":\"");
  39. sb.Append(kv.Value);
  40. sb.Append("\"");
  41. }
  42. sb.Append("},");
  43. return _output.Replace("$types$", sb.ToString()).ToString();
  44. }
  45. return _output.ToString();
  46. }
  47. private void WriteValue(object obj)
  48. {
  49. if (obj == null || obj is DBNull)
  50. {
  51. _output.Append("null");
  52. }
  53. else if (obj is string || obj is char)
  54. {
  55. WriteString(obj.ToString());
  56. }
  57. else if (obj is Guid)
  58. {
  59. WriteGuid((Guid)obj);
  60. }
  61. else if (obj is bool)
  62. {
  63. _output.Append(((bool)obj) ? "true" : "false");
  64. }
  65. else if (obj is int || obj is long || obj is double || obj is decimal || obj is float || obj is byte || obj is short || obj is sbyte || obj is ushort || obj is uint || obj is ulong)
  66. {
  67. _output.Append(((IConvertible)obj).ToString(NumberFormatInfo.InvariantInfo));
  68. }
  69. else if (obj is DateTime)
  70. {
  71. WriteDateTime((DateTime)obj);
  72. }
  73. else if (obj is IDictionary && obj.GetType().IsGenericType && obj.GetType().GetGenericArguments()[0] == typeof(string))
  74. {
  75. WriteStringDictionary((IDictionary)obj);
  76. }
  77. else if (obj is IDictionary)
  78. {
  79. WriteDictionary((IDictionary)obj);
  80. }
  81. else if (obj is DataSet)
  82. {
  83. WriteDataset((DataSet)obj);
  84. }
  85. else if (obj is DataTable)
  86. {
  87. WriteDataTable((DataTable)obj);
  88. }
  89. else if (obj is byte[])
  90. {
  91. WriteBytes((byte[])obj);
  92. }
  93. else if (obj is Array || obj is IList || obj is ICollection)
  94. {
  95. WriteArray((IEnumerable)obj);
  96. }
  97. else if (obj is Enum)
  98. {
  99. WriteEnum((Enum)obj);
  100. }
  101. else
  102. {
  103. WriteObject(obj);
  104. }
  105. }
  106. private void WriteEnum(Enum e)
  107. {
  108. WriteStringFast(e.ToString());
  109. }
  110. private void WriteGuid(Guid g)
  111. {
  112. if (!_params.UseFastGuid)
  113. {
  114. WriteStringFast(g.ToString());
  115. }
  116. else
  117. {
  118. WriteBytes(g.ToByteArray());
  119. }
  120. }
  121. private void WriteBytes(byte[] bytes)
  122. {
  123. WriteStringFast(Convert.ToBase64String(bytes, 0, bytes.Length, Base64FormattingOptions.None));
  124. }
  125. private void WriteDateTime(DateTime dateTime)
  126. {
  127. DateTime dt = dateTime;
  128. if (_params.UseUTCDateTime)
  129. {
  130. dt = dateTime.ToUniversalTime();
  131. }
  132. _output.Append("\"");
  133. _output.Append(dt.Year.ToString("0000", NumberFormatInfo.InvariantInfo));
  134. _output.Append("-");
  135. _output.Append(dt.Month.ToString("00", NumberFormatInfo.InvariantInfo));
  136. _output.Append("-");
  137. _output.Append(dt.Day.ToString("00", NumberFormatInfo.InvariantInfo));
  138. _output.Append(" ");
  139. _output.Append(dt.Hour.ToString("00", NumberFormatInfo.InvariantInfo));
  140. _output.Append(":");
  141. _output.Append(dt.Minute.ToString("00", NumberFormatInfo.InvariantInfo));
  142. _output.Append(":");
  143. _output.Append(dt.Second.ToString("00", NumberFormatInfo.InvariantInfo));
  144. if (_params.UseUTCDateTime)
  145. {
  146. _output.Append("Z");
  147. }
  148. _output.Append("\"");
  149. }
  150. private DatasetSchema GetSchema(DataTable ds)
  151. {
  152. if (ds == null)
  153. {
  154. return null;
  155. }
  156. DatasetSchema i = new DatasetSchema();
  157. i.Info = new List<string>();
  158. i.Name = ds.TableName;
  159. foreach (DataColumn c in ds.Columns)
  160. {
  161. i.Info.Add(ds.TableName);
  162. i.Info.Add(c.ColumnName);
  163. i.Info.Add(c.DataType.ToString());
  164. }
  165. return i;
  166. }
  167. private DatasetSchema GetSchema(DataSet ds)
  168. {
  169. if (ds == null)
  170. {
  171. return null;
  172. }
  173. DatasetSchema i = new DatasetSchema();
  174. i.Info = new List<string>();
  175. i.Name = ds.DataSetName;
  176. foreach (DataTable t in ds.Tables)
  177. {
  178. foreach (DataColumn c in t.Columns)
  179. {
  180. i.Info.Add(t.TableName);
  181. i.Info.Add(c.ColumnName);
  182. i.Info.Add(c.DataType.ToString());
  183. }
  184. }
  185. return i;
  186. }
  187. private string GetXmlSchema(DataTable dt)
  188. {
  189. using StringWriter writer = new StringWriter();
  190. dt.WriteXmlSchema(writer);
  191. return dt.ToString();
  192. }
  193. private void WriteDataset(DataSet ds)
  194. {
  195. _output.Append('{');
  196. if (_params.UseExtensions)
  197. {
  198. WritePair("$schema", _params.UseOptimizedDatasetSchema ? ((object)GetSchema(ds)) : ((object)ds.GetXmlSchema()));
  199. _output.Append(',');
  200. }
  201. bool tablesep = false;
  202. foreach (DataTable table in ds.Tables)
  203. {
  204. if (tablesep)
  205. {
  206. _output.Append(",");
  207. }
  208. tablesep = true;
  209. WriteDataTableData(table);
  210. }
  211. _output.Append('}');
  212. }
  213. private void WriteDataTableData(DataTable table)
  214. {
  215. _output.Append('"');
  216. _output.Append(table.TableName);
  217. _output.Append("\":[");
  218. DataColumnCollection cols = table.Columns;
  219. bool rowseparator = false;
  220. foreach (DataRow row in table.Rows)
  221. {
  222. if (rowseparator)
  223. {
  224. _output.Append(",");
  225. }
  226. rowseparator = true;
  227. _output.Append('[');
  228. bool pendingSeperator = false;
  229. foreach (DataColumn column in cols)
  230. {
  231. if (pendingSeperator)
  232. {
  233. _output.Append(',');
  234. }
  235. WriteValue(row[column]);
  236. pendingSeperator = true;
  237. }
  238. _output.Append(']');
  239. }
  240. _output.Append(']');
  241. }
  242. private void WriteDataTable(DataTable dt)
  243. {
  244. _output.Append('{');
  245. if (_params.UseExtensions)
  246. {
  247. WritePair("$schema", _params.UseOptimizedDatasetSchema ? ((object)GetSchema(dt)) : ((object)GetXmlSchema(dt)));
  248. _output.Append(',');
  249. }
  250. WriteDataTableData(dt);
  251. _output.Append('}');
  252. }
  253. private void WriteObject(object obj)
  254. {
  255. if (!_params.UsingGlobalTypes)
  256. {
  257. _output.Append('{');
  258. }
  259. else if (!_TypesWritten)
  260. {
  261. _output.Append("{$types$");
  262. }
  263. else
  264. {
  265. _output.Append("{");
  266. }
  267. _TypesWritten = true;
  268. _current_depth++;
  269. if (_current_depth > _MAX_DEPTH)
  270. {
  271. throw new Exception("Serializer encountered maximum depth of " + _MAX_DEPTH);
  272. }
  273. Dictionary<string, string> map = new Dictionary<string, string>();
  274. Type t = obj.GetType();
  275. bool append = false;
  276. if (_params.UseExtensions)
  277. {
  278. if (!_params.UsingGlobalTypes)
  279. {
  280. WritePairFast("$type", Reflection.Instance.GetTypeAssemblyName(t));
  281. }
  282. else
  283. {
  284. int dt = 0;
  285. string ct = Reflection.Instance.GetTypeAssemblyName(t);
  286. if (!_globalTypes.TryGetValue(ct, out dt))
  287. {
  288. dt = _globalTypes.Count + 1;
  289. _globalTypes.Add(ct, dt);
  290. }
  291. WritePairFast("$type", dt.ToString());
  292. }
  293. append = true;
  294. }
  295. List<Getters> g = Reflection.Instance.GetGetters(t);
  296. foreach (Getters p in g)
  297. {
  298. if (append)
  299. {
  300. _output.Append(',');
  301. }
  302. object o = p.Getter(obj);
  303. if ((o == null || o is DBNull) && !_params.SerializeNullValues)
  304. {
  305. append = false;
  306. continue;
  307. }
  308. WritePair(p.Name, o);
  309. if (o != null && _params.UseExtensions)
  310. {
  311. Type tt = o.GetType();
  312. if (tt == typeof(object))
  313. {
  314. map.Add(p.Name, tt.ToString());
  315. }
  316. }
  317. append = true;
  318. }
  319. if (map.Count > 0 && _params.UseExtensions)
  320. {
  321. _output.Append(",\"$map\":");
  322. WriteStringDictionary(map);
  323. }
  324. _current_depth--;
  325. _output.Append('}');
  326. _current_depth--;
  327. }
  328. private void WritePairFast(string name, string value)
  329. {
  330. if (value != null || _params.SerializeNullValues)
  331. {
  332. WriteStringFast(name);
  333. _output.Append(':');
  334. WriteStringFast(value);
  335. }
  336. }
  337. private void WritePair(string name, object value)
  338. {
  339. if ((value != null && !(value is DBNull)) || _params.SerializeNullValues)
  340. {
  341. WriteStringFast(name);
  342. _output.Append(':');
  343. WriteValue(value);
  344. }
  345. }
  346. private void WriteArray(IEnumerable array)
  347. {
  348. _output.Append('[');
  349. bool pendingSeperator = false;
  350. foreach (object obj in array)
  351. {
  352. if (pendingSeperator)
  353. {
  354. _output.Append(',');
  355. }
  356. WriteValue(obj);
  357. pendingSeperator = true;
  358. }
  359. _output.Append(']');
  360. }
  361. private void WriteStringDictionary(IDictionary dic)
  362. {
  363. _output.Append('{');
  364. bool pendingSeparator = false;
  365. foreach (DictionaryEntry entry in dic)
  366. {
  367. if (pendingSeparator)
  368. {
  369. _output.Append(',');
  370. }
  371. WritePair((string)entry.Key, entry.Value);
  372. pendingSeparator = true;
  373. }
  374. _output.Append('}');
  375. }
  376. private void WriteDictionary(IDictionary dic)
  377. {
  378. _output.Append('[');
  379. bool pendingSeparator = false;
  380. foreach (DictionaryEntry entry in dic)
  381. {
  382. if (pendingSeparator)
  383. {
  384. _output.Append(',');
  385. }
  386. _output.Append('{');
  387. WritePair("k", entry.Key);
  388. _output.Append(",");
  389. WritePair("v", entry.Value);
  390. _output.Append('}');
  391. pendingSeparator = true;
  392. }
  393. _output.Append(']');
  394. }
  395. private void WriteStringFast(string s)
  396. {
  397. _output.Append('"');
  398. _output.Append(s);
  399. _output.Append('"');
  400. }
  401. private void WriteString(string s)
  402. {
  403. _output.Append('"');
  404. int runIndex = -1;
  405. for (int index = 0; index < s.Length; index++)
  406. {
  407. char c = s[index];
  408. if (c >= ' ' && c < '\u0080' && c != '"' && c != '\\')
  409. {
  410. if (runIndex == -1)
  411. {
  412. runIndex = index;
  413. }
  414. continue;
  415. }
  416. if (runIndex != -1)
  417. {
  418. _output.Append(s, runIndex, index - runIndex);
  419. runIndex = -1;
  420. }
  421. switch (c)
  422. {
  423. case '\t':
  424. _output.Append("\\t");
  425. break;
  426. case '\r':
  427. _output.Append("\\r");
  428. break;
  429. case '\n':
  430. _output.Append("\\n");
  431. break;
  432. case '"':
  433. case '\\':
  434. _output.Append('\\');
  435. _output.Append(c);
  436. break;
  437. default:
  438. {
  439. _output.Append("\\u");
  440. StringBuilder output = _output;
  441. int num = c;
  442. output.Append(num.ToString("X4", NumberFormatInfo.InvariantInfo));
  443. break;
  444. }
  445. }
  446. }
  447. if (runIndex != -1)
  448. {
  449. _output.Append(s, runIndex, s.Length - runIndex);
  450. }
  451. _output.Append('"');
  452. }
  453. }