use std::net::TcpStream;
use df_helper::files::file;
use std::io::{Read, Write};
use std::process::exit;
use futures::{executor, FutureExt, StreamExt};
use kafka::producer::AsBytes;
use sqlx::{Connection, Executor, MssqlConnection, MssqlPool, Row};
use sqlx::mssql::{Mssql, MssqlRow};
//
fn main() {
    // let co=Ms::connect();
    // let mut co = executor::block_on(co);
    // co.fieldsinfo()
}
//
//
// struct Ms {
//     conn: MssqlConnection,
// }
//
// impl Ms {
//     #[actix_rt::main]
//     pub async fn connect() -> Self {
//         let url = "mssql://sa:snsoft@192.100.100.7:1433/sctest";
//         let res = MssqlConnection::connect(&url).await;
//         match res {
//             Ok(mut e) => {
//                 Self {
//                     conn: e
//                 }
//             }
//             Err(e) => {
//                 println!("{:#?}", e);
//                 exit(500)
//             }
//         }
//     }
//     pub async fn fieldsinfo(&mut self) {
//         let sql = "SELECT count(*) from purorder";
//         let value = sqlx::query(sql)
//             .try_map(|row: MssqlRow| {
//                 row.try_get::<i32, _>(0)
//             }).fetch_one(&mut self.conn).await;
//         println!(">>>> {:#?}", value);
//     }
// }