search

taosdata / TDengine

High-performance, scalable time-series database designed for Industrial IoT (IIoT) scenarios
https://tdengine.com
GNU Affero General Public License v3.0
23.42k stars 4.87k forks source link

c# 32 bit issue #9973

Closed xiaopenggogo closed 2 years ago

xiaopenggogo commented 2 years ago

image 使用的是客户端中的源码，在64位下正常，32位下失败。
语言：C# 版本：2.4.0.0

xiaopenggogo commented 2 years ago

image

xiaopenggogo commented 2 years ago

本地电脑没有安装32位的版本只安装的64位客户端。32位dll是在其他电脑上安装完拷到项目的运行的根目录的。也顺便拷贝到了C:/window/system32下

xiaopenggogo commented 2 years ago

C:/TDengine/cfg 顺便问一下这个目录下的东西需要替换成功32位的吗？我想实现根据项目运行环境自动选择dll版本。

xleili commented 2 years ago

C:/TDengine/cfg 顺便问一下这个目录下的东西需要替换成功32位的吗？我想实现根据项目运行环境自动选择dll版本。

这个路径下的都是配置文件，应该是不用替换成32位的

xleili commented 2 years ago

本地电脑没有安装32位的版本只安装的64位客户端。32位dll是在其他电脑上安装完拷到项目的运行的根目录的。也顺便拷贝到了C:/window/system32下

只有TDegine.init()会报错吗？还是其他的接口都会报错。我自己也搞个32位的windows虚拟机复现一下。

xiaopenggogo commented 2 years ago

初始化报错，其他接口就走不下去了吧。 很奇怪的问题，我在控制台程序无论是32位还是64位都正常，只要在webserver里面32位才会出现这个错误。您那边可以试试使用webserver工程调用复现。

xiaopenggogo commented 2 years ago

/*

using System; using System.Text; using System.Collections.Generic; using System.Runtime.InteropServices; using System.Collections; namespace TDengineDriver { public class TDengineTest { //connect parameters private string host; private string configDir; private string user; private string password; private short port = 0;

    //sql parameters
    private string dbName;
    private string stableName;
    private string tablePrefix;

    private bool isInsertData;
    private bool isQueryData;

    private long tableCount;
    private long totalRows;
    private long batchRows;
    private long beginTimestamp = 1551369600000L;

    private IntPtr conn = IntPtr.Zero;
    private long rowsInserted = 0;

    public void GetTaos()
    {
        host = "192.168.1.40";
        user = "root";
        password = "taosdata";
        dbName = "sisdata";
        stableName = "hisdata";
        configDir = "C:/TDengine/cfg";
        InitTDengine();
        ConnectTDengine();
        //CreateDbAndTable();
        //ExecuteInsert();
        //ExecuteQuery();
        //CloseConnection();

    }

    public void InitTDengine()
    {
        TDengine.Options((int)TDengineInitOption.TDDB_OPTION_CONFIGDIR, this.configDir);
        TDengine.Options((int)TDengineInitOption.TDDB_OPTION_SHELL_ACTIVITY_TIMER, "60");
        TDengine.Init();
        Console.WriteLine("TDengine Initialization finished");
    }

    public void ConnectTDengine()
    {
        string db = "";
        Console.WriteLine("Host:{0}", this.host);
        this.conn = TDengine.Connect(this.host, this.user, this.password, db, this.port);
        if (this.conn == IntPtr.Zero)
        {
            Console.WriteLine("Connect to TDengine failed");
            ExitProgram();
        }
        else
        {
            Console.WriteLine("Connect to TDengine success");
        }
    }

    public void CreateDbAndTable()
    {
        if (!this.isInsertData)
        {
            return;
        }

        StringBuilder sql = new StringBuilder();
        sql.Append("create database if not exists ").Append(this.dbName);
        IntPtr res = TDengine.Query(this.conn, sql.ToString());
        if ((res == IntPtr.Zero) || (TDengine.ErrorNo(res) != 0))
        {
            Console.Write(sql.ToString() + " failure, ");
            if (res != IntPtr.Zero)
            {
                Console.Write("reason: " + TDengine.Error(res));
            }
            Console.WriteLine("");
            ExitProgram();
        }
        else
        {
            Console.WriteLine(sql.ToString() + " success");
        }
        TDengine.FreeResult(res);

        sql.Clear();
        sql.Append("use ").Append(this.dbName);
        res = TDengine.Query(this.conn, sql.ToString());
        if ((res == IntPtr.Zero) || (TDengine.ErrorNo(res) != 0))
        {
            Console.Write(sql.ToString() + " failure, ");
            if (res != IntPtr.Zero)
            {
                Console.Write("reason: " + TDengine.Error(res));
            }
            Console.WriteLine("");
            ExitProgram();
        }
        else
        {
            Console.WriteLine(sql.ToString() + " success");
        }
        TDengine.FreeResult(res);

        sql.Clear();
        sql.Append("create table if not exists ").Append(this.stableName).Append("(ts timestamp, v1 bool, v2 tinyint, v3 smallint, v4 int, v5 bigint, v6 float, v7 double, v8 binary(10), v9 nchar(10)) tags(t1 int)");
        res = TDengine.Query(this.conn, sql.ToString());
        if ((res == IntPtr.Zero) || (TDengine.ErrorNo(res) != 0))
        {
            Console.Write(sql.ToString() + " failure, ");
            if (res != IntPtr.Zero)
            {
                Console.Write("reason: " + TDengine.Error(res));
            }
            Console.WriteLine("");
            ExitProgram();
        }
        else
        {
            Console.WriteLine(sql.ToString() + " success");
        }
        TDengine.FreeResult(res);

        for (int i = 0; i < this.tableCount; i++)
        {
            sql.Clear();
            sql = sql.Append("create table if not exists ").Append(this.tablePrefix).Append(i)
              .Append(" using ").Append(this.stableName).Append(" tags(").Append(i).Append(")");
            res = TDengine.Query(this.conn, sql.ToString());
            if ((res == IntPtr.Zero) || (TDengine.ErrorNo(res) != 0))
            {
                Console.Write(sql.ToString() + " failure, ");
                if (res != IntPtr.Zero)
                {
                    Console.Write("reason: " + TDengine.Error(res));
                }
                Console.WriteLine("");
                ExitProgram();
            }
            else
            {
                Console.WriteLine(sql.ToString() + " success");
            }
            TDengine.FreeResult(res);
        }

        Console.WriteLine("create db and table success");
    }

    public void ExecuteInsert()
    {
        if (!this.isInsertData)
        {
            return;
        }

        System.DateTime start = new System.DateTime();
        long loopCount = this.totalRows / this.batchRows;

        for (int table = 0; table < this.tableCount; ++table)
        {
            for (long loop = 0; loop < loopCount; loop++)
            {
                StringBuilder sql = new StringBuilder();
                sql.Append("insert into ").Append(this.tablePrefix).Append(table).Append(" values");
                for (int batch = 0; batch < this.batchRows; ++batch)
                {

                    long rows = loop * this.batchRows + batch;
                    sql.Append("(")
                       .Append(this.beginTimestamp + rows)
                       .Append(", 1, 2, 3,")
                       .Append(rows)
                       .Append(", 5, 6, 7, 'abc', 'def')");
                }
                IntPtr res = TDengine.Query(this.conn, sql.ToString());

                if ((res == IntPtr.Zero) || (TDengine.ErrorNo(res) != 0))
                {
                    Console.Write(sql.ToString() + " failure, ");
                    if (res != IntPtr.Zero)
                    {
                        Console.Write("reason: " + TDengine.Error(res));
                    }
                    Console.WriteLine("");
                }

                int affectRows = TDengine.AffectRows(res);
                this.rowsInserted += affectRows;

                TDengine.FreeResult(res);
            }
        }

        System.DateTime end = new System.DateTime();
        TimeSpan ts = end - start;

        Console.Write("Total {0:G} rows inserted, {1:G} rows failed, time spend {2:G} seconds.\n"
          , this.rowsInserted, this.totalRows * this.tableCount - this.rowsInserted, ts.TotalSeconds);
    }

    public void ExecuteQuery()
    {
        if (!this.isQueryData)
        {
            return;
        }

        System.DateTime start = new System.DateTime();
        long queryRows = 0;

        for (int i = 0; i < 1/*this.tableCount*/; ++i)
        {
            String sql = "select * from " + this.dbName + "." + tablePrefix + i;
            Console.WriteLine(sql);

            IntPtr res = TDengine.Query(conn, sql);
            if ((res == IntPtr.Zero) || (TDengine.ErrorNo(res) != 0))
            {
                Console.Write(sql.ToString() + " failure, ");
                if (res != IntPtr.Zero)
                {
                    Console.Write("reason: " + TDengine.Error(res));
                }
                Console.WriteLine("");
                ExitProgram();
            }

            int fieldCount = TDengine.FieldCount(res);
            Console.WriteLine("field count: " + fieldCount);

            List<TDengineMeta> metas = TDengine.FetchFields(res);
            for (int j = 0; j < metas.Count; j++)
            {
                TDengineMeta meta = (TDengineMeta)metas[j];
                Console.WriteLine("index:" + j + ", type:" + meta.type + ", typename:" + meta.TypeName() + ", name:" + meta.name + ", size:" + meta.size);
            }

            IntPtr rowdata;
            StringBuilder builder = new StringBuilder();
            while ((rowdata = TDengine.FetchRows(res)) != IntPtr.Zero)
            {
                queryRows++;
                for (int fields = 0; fields < fieldCount; ++fields)
                {
                    TDengineMeta meta = metas[fields];
                    int offset = IntPtr.Size * fields;
                    IntPtr data = Marshal.ReadIntPtr(rowdata, offset);

                    builder.Append("---");

                    if (data == IntPtr.Zero)
                    {
                        builder.Append("NULL");
                        continue;
                    }

                    switch ((TDengineDataType)meta.type)
                    {
                        case TDengineDataType.TSDB_DATA_TYPE_BOOL:
                            bool v1 = Marshal.ReadByte(data) == 0 ? false : true;
                            builder.Append(v1);
                            break;
                        case TDengineDataType.TSDB_DATA_TYPE_TINYINT:
                            byte v2 = Marshal.ReadByte(data);
                            builder.Append(v2);
                            break;
                        case TDengineDataType.TSDB_DATA_TYPE_SMALLINT:
                            short v3 = Marshal.ReadInt16(data);
                            builder.Append(v3);
                            break;
                        case TDengineDataType.TSDB_DATA_TYPE_INT:
                            int v4 = Marshal.ReadInt32(data);
                            builder.Append(v4);
                            break;
                        case TDengineDataType.TSDB_DATA_TYPE_BIGINT:
                            long v5 = Marshal.ReadInt64(data);
                            builder.Append(v5);
                            break;
                        case TDengineDataType.TSDB_DATA_TYPE_FLOAT:
                            float v6 = (float)Marshal.PtrToStructure(data, typeof(float));
                            builder.Append(v6);
                            break;
                        case TDengineDataType.TSDB_DATA_TYPE_DOUBLE:
                            double v7 = (double)Marshal.PtrToStructure(data, typeof(double));
                            builder.Append(v7);
                            break;
                        case TDengineDataType.TSDB_DATA_TYPE_BINARY:
                            string v8 = Marshal.PtrToStringAnsi(data);
                            builder.Append(v8);
                            break;
                        case TDengineDataType.TSDB_DATA_TYPE_TIMESTAMP:
                            long v9 = Marshal.ReadInt64(data);
                            builder.Append(v9);
                            break;
                        case TDengineDataType.TSDB_DATA_TYPE_NCHAR:
                            string v10 = Marshal.PtrToStringAnsi(data);
                            builder.Append(v10);
                            break;
                        case TDengineDataType.TSDB_DATA_TYPE_UTINYINT:
                            byte v11 = Marshal.ReadByte(data);
                            builder.Append(v11);
                            break;
                        case TDengineDataType.TSDB_DATA_TYPE_USMALLINT:
                            ushort v12 = (ushort)Marshal.ReadInt16(data);
                            builder.Append(v12);
                            break;
                        case TDengineDataType.TSDB_DATA_TYPE_UINT:
                            uint v13 = (uint)Marshal.ReadInt32(data);
                            builder.Append(v13);
                            break;
                        case TDengineDataType.TSDB_DATA_TYPE_UBIGINT:
                            ulong v14 = (ulong)Marshal.ReadInt64(data);
                            builder.Append(v14);
                            break;
                    }
                }
                builder.Append("---");

                if (queryRows <= 10)
                {
                    Console.WriteLine(builder.ToString());
                }
                builder.Clear();
            }

            if (TDengine.ErrorNo(res) != 0)
            {
                Console.Write("Query is not complete, Error {0:G}",
                    TDengine.ErrorNo(res), TDengine.Error(res));
            }
            Console.WriteLine("");

            TDengine.FreeResult(res);
        }

        System.DateTime end = new System.DateTime();
        TimeSpan ts = end - start;

        Console.Write("Total {0:G} rows inserted, {1:G} rows query, time spend {2:G} seconds.\n"
         , this.rowsInserted, queryRows, ts.TotalSeconds);
    }

    public void CloseConnection()
    {
        if (this.conn != IntPtr.Zero)
        {
            TDengine.Close(this.conn);
        }
    }

    static void ExitProgram()
    {
        TDengine.Cleanup();
        System.Environment.Exit(0);
    }
}

}

xiaopenggogo commented 2 years ago

using System; using System.Collections.Generic; using System.Linq; using System.Web; using System.Web.Services; using TDengineDriver;

namespace WebApplication1 { ///

/// WebService1 的摘要说明 /// [WebService(Namespace = "http://tempuri.org/")] [WebServiceBinding(ConformsTo = WsiProfiles.BasicProfile1_1)] [System.ComponentModel.ToolboxItem(false)] // 若要允许使用 ASP.NET AJAX 从脚本中调用此 Web 服务，请取消注释以下行。 // [System.Web.Script.Services.ScriptService] public class WebService1 : System.Web.Services.WebService {

    [WebMethod]
    public string GetTaos()
    {
        TDengineTest test = new TDengineTest();

        test.GetTaos();

        return "";
    }
}

}

xiaopenggogo commented 2 years ago

image

xiaopenggogo commented 2 years ago

P30@FK9 S)DT_6`MC WI$HQ

xiaopenggogo commented 2 years ago

PER`(Z$EQEW%E93H3ZL)P2O

xiaopenggogo commented 2 years ago

我刚才在别人电脑安装的32位客户端，试试一下。控制台程序32、64都正常。 32位webserver初始化就报错，64位正常。。 验证了跟这个C:/TDengine/cfg没有关系。麻烦您告诉我怎么处理，谢谢

xiaopenggogo commented 2 years ago

image 将init()注释了，走下面连接也是那个错误

xleili commented 2 years ago

我们尽快确认一下，有问题尽快修复

xleili commented 2 years ago

This issue is stale because it has been open for 30 days with no activity.