C#/c#

[ c# ] MySqlConnector 로 mysql select , insert

code094 2022. 12. 26. 09:51
public class TestResultDTO
    {
        public int id { get; set; }
        public string name { get; set; }
        public float score { get; set; }
    }

insert and select 

public class MysqlConnector
    {
        private MySqlConnection connection = new MySqlConnection("Server=severip;User ID=id;Password=password;Database=db_name;Port=port");
        public MysqlConnector()
        {
            connection.Open();
        }

        public void MysqlConnectorSelect(string date)
        {
            List<TestResultDTO> resultList = new List<TestResultDTO>();
            if (connection.State != System.Data.ConnectionState.Open) connection.Open();
           
                string sql = "select id , table_name.NAME ,score from table_name where score >= 85 ";

                var command = new MySqlCommand(sql, connection);           
                // command.CommandTimeout = 9000000;

                var reader = command.ExecuteReader();
                while (reader.Read())
                    {

                        TestResultDTO result = new TestResultDTO();
                        result.Name =  reader.GetInt32(0);
                        result.Detecttime =  reader.GetString(1);
                        result.Countvalue = reader.GetFloat(2);
                        

                        resultList.Add(result);
                    }
            
            
            // Console.WriteLine(resultList.Count());
            connection.Close();
        }
        
        public void MysqlConnectorInsert(TestResultDTO result)
        {
            string insertQuery = String.Format("INSERT INTO table_name (id,name,score) VALUES('{0}','{1}','{2}')"
                            , result.id,  result.name, result.score);

            MySqlCommand command = new MySqlCommand(insertQuery, connection);

            //if (command.ExecuteNonQuery() == 1)
            //{
            //    Console.WriteLine("인서트 성공");
            //}
            //else
            //{
            //    Console.WriteLine("인서트 실패");
            //}
        }
    }