CppGetRoutine.cs

Go to the documentation of this file.

using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Text;
using MySql.Data.MySqlClient;

namespace RoutineAnalyzer
{
    class CppGetRoutine : GetRoutineBase
    {
        public CppGetRoutine(string sql)
            : base(sql)
        {
        }

        public override string GetDeclaration()
        {
            StringBuilder builder = new StringBuilder();
            builder.Append("static __declspec(dllexport) void ");
            builder.Append(ParseHelper.ConvertUnderscoreToCamelCase(_name));
            builder.Append("(");
            foreach (RoutineParamBase param in _params)
            {
                builder.Append(param.GetDeclaration());
                builder.Append(", ");
            }

            builder.Append("int* queryId");

            builder.Append(")");
            return builder.ToString();
        }

        public override string GetCode()
        {
            //start off with the declaration, then put in
            StringBuilder builder = new StringBuilder();
            builder.AppendLine(GetDeclaration().Replace("static __declspec(dllexport) ", ""));
            builder.AppendLine("{");

            //choose to start a new stream or continue an existing one
            builder.AppendLine("DbStream* stream;");
            builder.AppendLine("if(*queryId == DbStream::InitStreamId)");
            builder.Append("    stream = DbStream::StartStream(formatString(\"CALL ");
            builder.Append(_name);
            builder.Append("(%d)\",");
            builder.Append(_params.First().GetPreExecuteCode());
            builder.AppendLine("));");
            builder.AppendLine("else");
            builder.AppendLine("    stream = DbStream::RetrieveStream(queryId);");

            builder.AppendLine("if(stream == NULL)");
            builder.AppendLine("    return;");

            for (int i = 1; i < _params.Count; ++i)
                builder.AppendLine(_params[i].GetPostExecuteCode());

            builder.AppendLine("if(!DbStream::CheckHasMoreRows(stream, queryId))");
            builder.AppendLine("    *queryId = DbStream::InitStreamId;");

            //close up the statement and return it
            builder.Append("}");
            return builder.ToString();
        }

        protected override RoutineParamBase CreateRoutineParam(string sql, int index)
        {
            return new CppGetRoutineParam(sql, index);
        }
    }
}