CppSetRoutine.cs

Go to the documentation of this file.

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;

namespace RoutineAnalyzer
{
    class CppSetRoutine : RoutineBase
    {
        public CppSetRoutine(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());
                if (param != _params.Last<RoutineParamBase>())
                    builder.Append(", ");
            }

            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("{");

            //create the prepared statement that we will call
            //this prepared statement include the routine name and a number of question marks
            //equal to the number of arguments
            builder.AppendLine("sql::Connection* connection = SraData::DbConnectionFactory::GetSingleton().getConnection();");
            //use auto_ptr so we don't lose any memory in here
            builder.AppendLine("std::auto_ptr<sql::PreparedStatement> pstmt;");
            builder.Append("pstmt.reset(connection->prepareStatement(\"CALL ");
            builder.Append(_name);
            builder.Append("(");
            for (int i = 0; i < _params.Count; ++i)
            {
                builder.Append(_params[i].GetParameter());
                if (_params[i] != _params.Last<RoutineParamBase>())
                    builder.Append(",");
            }
            builder.AppendLine(")\"));");

            //add the pre-execute code for each parameter
            for (int i = 0; i < _params.Count; ++i)
            {
                string code = _params[i].GetPreExecuteCode();
                if (string.IsNullOrEmpty(code))
                    continue;
                builder.AppendLine(code);
            }

            //add the execute statement
            builder.AppendLine();
            builder.AppendLine("pstmt->execute();");
            builder.AppendLine();

            //add the post-execute code for each parameter
            for (int i = 0; i < _params.Count; ++i)
            {
                string code = _params[i].GetPostExecuteCode();
                if (string.IsNullOrEmpty(code))
                    continue;
                builder.AppendLine(code);
            }

            builder.AppendLine("SraData::DbConnectionFactory::GetSingleton().recycleConnection(connection);");

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

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