ContainsRowNumberChecker.cs 2.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Text;
  4. namespace System.Data.Linq.SqlClient {
  5. internal class SqlRowNumberChecker {
  6. Visitor rowNumberVisitor;
  7. internal SqlRowNumberChecker() {
  8. this.rowNumberVisitor = new Visitor();
  9. }
  10. internal bool HasRowNumber(SqlNode node) {
  11. this.rowNumberVisitor.Visit(node);
  12. return rowNumberVisitor.HasRowNumber;
  13. }
  14. internal bool HasRowNumber(SqlRow row) {
  15. foreach (SqlColumn column in row.Columns) {
  16. if (this.HasRowNumber(column)) {
  17. return true;
  18. }
  19. }
  20. return false;
  21. }
  22. internal SqlColumn RowNumberColumn {
  23. get {
  24. return rowNumberVisitor.HasRowNumber ? rowNumberVisitor.CurrentColumn : null;
  25. }
  26. }
  27. private class Visitor: SqlVisitor {
  28. bool hasRowNumber = false;
  29. public bool HasRowNumber {
  30. get { return hasRowNumber; }
  31. }
  32. public SqlColumn CurrentColumn { private set; get; }
  33. internal override SqlRowNumber VisitRowNumber(SqlRowNumber rowNumber) {
  34. this.hasRowNumber = true;
  35. return rowNumber;
  36. }
  37. // shortcuts
  38. internal override SqlExpression VisitScalarSubSelect(SqlSubSelect ss) {
  39. return ss;
  40. }
  41. internal override SqlExpression VisitSubSelect(SqlSubSelect ss) {
  42. return ss;
  43. }
  44. internal override SqlRow VisitRow(SqlRow row)
  45. {
  46. for (int i = 0, n = row.Columns.Count; i < n; i++) {
  47. row.Columns[i].Expression = this.VisitExpression(row.Columns[i].Expression);
  48. if (this.hasRowNumber) {
  49. this.CurrentColumn = row.Columns[i];
  50. break;
  51. }
  52. }
  53. return row;
  54. }
  55. internal override SqlSelect VisitSelect(SqlSelect select) {
  56. this.Visit(select.Row);
  57. this.Visit(select.Where);
  58. return select;
  59. }
  60. }
  61. }
  62. }