//using DTTest;
using Newtonsoft.Json;
using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Net.Http;
using System.ServiceModel.Channels;
using System.Text;
using System.Threading.Tasks;
using System.Web;
using System.Web.Http;
using DataLinkMesWork;
//using static DTTest.SqlOperation;
using System.Collections.Specialized;
using System.Data.SqlClient;
using System.Configuration;

namespace WinformApiApp.Controller
{

    [RoutePrefix("api/SQLCommon")]
    public class SQLCommonController : ApiController
    {
        public static string PP_ConnectionStr  = ConfigurationManager.AppSettings["ConnectionString_MES"];
        /// <summary>
        /// http://localhost:41181/api/SQLCommon/ExecuteNonQuery?sql=sqlStr
        /// http://localhost:41181/api/SQLCommon/ExecuteDataset?sql=sqlStr
        /// http://localhost:41181/api/SQLCommon/ExecuteNonQuery?sql=sqlStr
        /// </summary>
        /// <param name="sql"></param>
        /// <returns></returns>
        [HttpGet]
        public string ExecuteNonQuery1(string sql)
        {
            StringCollection sql1 = JsonConvert.DeserializeObject<StringCollection>(sql);

            string errorMessage;
            return SQLCommon.ExecuteNonQuery(sql1, PP_ConnectionStr, out  errorMessage).ToString();
        }
        [HttpGet]
        public string ExecuteNonQuery(string sql)
        {
            string errorMessage;
            return SQLCommon.ExecuteNonQuery(sql, PP_ConnectionStr, out errorMessage).ToString();
        }

        [HttpGet]
        public string ExecuteOutNum(string sql)
        {
            int count;
            string errorMessage;
            SQLCommon.ExecuteOutNum( sql, PP_ConnectionStr, out  count, out  errorMessage);
            return count.ToString();
        }

        [HttpGet]
        public HttpResponseMessage ExecuteDataset(string sql)
        {
            DataSet ds;
            string errorMessage;
            SQLCommon.ExecuteDataset(sql, PP_ConnectionStr, out ds, out errorMessage);
            var pp = JsonConvert.SerializeObject(ds);

            HttpResponseMessage result = new HttpResponseMessage { Content = new StringContent(pp, Encoding.GetEncoding("UTF-8"), "application/json") };
            return result;
        }

        [HttpGet]
        public HttpResponseMessage ExecuteDataTable(string sql)
        {
            DataTable dt;
            string errorMessage;
            SQLCommon.ExecuteDataTable(sql, PP_ConnectionStr, out dt, out errorMessage);
            var pp = JsonConvert.SerializeObject(dt);

            HttpResponseMessage result = new HttpResponseMessage { Content = new StringContent(pp, Encoding.GetEncoding("UTF-8"), "application/json") };
            return result;
        }


        [HttpGet]
        public HttpResponseMessage ExecuteDataReader(string sql)
        {
            SqlDataReader dr;
            string errorMessage;
            SQLCommon.ExecuteDataReader(sql, PP_ConnectionStr, out dr, out errorMessage);
            var pp = JsonConvert.SerializeObject(dr);

            HttpResponseMessage result = new HttpResponseMessage { Content = new StringContent(pp, Encoding.GetEncoding("UTF-8"), "application/json") };
            return result;
        }

        /// <summary>
        /// 执行SQL语句，增、删、改，无返回
        /// </summary>
        /// <param name="sql"></param>
        /// <param name="connectionString"></param>
        /// <param name="errorMessage"></param>
        /// <returns></returns>
        [HttpGet]
        public string ExecuteSql(string sql)
        { 
            string errorMessage;
            return SQLCommon.ExecuteSql( sql, PP_ConnectionStr, out errorMessage).ToString();
        }


        /// <summary>
        /// 执行SQL语句，查询，返回表
        /// </summary>
        /// <param name="sql"></param>
        /// <param name="connectionString"></param>
        /// <param name="dt"></param>
        /// <param name="errorMessage"></param>
        /// <returns></returns>
        [HttpGet]
        public HttpResponseMessage ExecuteSqlDataTable(string sql)
        {
            DataTable dt;
            string errorMessage;
            SQLCommon.ExecuteSql(sql, PP_ConnectionStr, out dt, out errorMessage);
            var pp = JsonConvert.SerializeObject(dt);

            HttpResponseMessage result = new HttpResponseMessage { Content = new StringContent(pp, Encoding.GetEncoding("UTF-8"), "application/json") };
            return result;
        }
    }
}