《数据资产管理核心技术与应用》读书笔记-第四章：数据质量的技术实现（二）

public class ObjectBingVariables extends HashMap<String,Object>{privateObject objectValue;private Map<String,Object> cache = new HashMap<>();publicObjectBingVariables(Object objectValue){

        Objects.requireNonNull(objectValue,"传入得查询参数不能为null！");this.objectValue =objectValue;

        init(objectValue);

    }private voidinit(Object dto){try{

            Method[] methods=dto.getClass().getMethods();for(Method method : methods) {if (method.getName().startsWith("get") && method.getParameterCount() == 0) {

                    Object value=method.invoke(dto);

                    String key= method.getName().substring(3);this.put(key.toUpperCase(),value);

                }

            }

        }catch(Exception ex){throw newRuntimeException(ex);

        }

    }



    @OverridepublicObject put(String key, Object value) {returnsuper.put(key.toUpperCase(), value);

    }



    @Overridepublic Object get(Object key) {return super.get(String.valueOf(key).toUpperCase());

    }

}

public class FunctionBindVariables extends HashMap<String,Object>{privateString sql;private Function<String,Object>function;public FunctionBindVariables(String sql, Function<String,Object>function){this.sql =sql;this.function =function;

    }public static Map<String,Object> from(String sql, Function<String,Object>function){return newFunctionBindVariables(sql,function);

    }



    @Overridepublic Object get(Object key) {return "sql".equals(key) ? this.sql : function.apply((String)key);

    }

}

public class SingletonBindVariables extends HashMap<String,Object>{publicSingletonBindVariables(String sql, Object param){

        put("sql",sql);

        put("param",param);

    }public static Map<String,Object> from(String sql, Object param){return newSingletonBindVariables(sql,param);

    }





    @Overridepublic Object get(Object key) {return "sql".equals(key) ? super.get("sql") : super.get("param");

    }



}

import org.apache.ibatis.type.JdbcType;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;



import java.util.*;

import java.util.function.Function;public classGrid  {private static final Logger log = LoggerFactory.getLogger(Grid.class);privateJdbcType[] jdbcTypes;private int MaxCol = 0;private int MaxRow = 0;private int MaxNumber = 0;private List<String> data = newArrayList();public Grid(intmaxCol) {this.MaxCol =maxCol;

    }protected voidaddText(String text) {this.data.add(text);int size = this.data.size();if (size > this.MaxCol) {this.MaxNumber = size - this.MaxCol;if (this.MaxNumber % this.MaxCol == 0) {this.MaxRow = this.MaxNumber / this.MaxCol;

            }else{this.MaxRow = this.MaxNumber / this.MaxCol + 1;

            }



        }

    }public <T> T getText(int row, int col, Function<String, T>function) {return function.apply(this.getText(row, col));

    }public String getText(introw, String ignoreCaseRowName) {return getText(row,ignoreCaseRowName,false);

    }/**

     * 根据行数和列名匹配对应得数据

     * @param row 列数

     * @param ignoreCaseRowName 忽略大小写得 列名

     * @param IgnoreUnmatchedColumn 忽略掉未匹配得列，当根据列名未找到数据时生效，true时如果列名不存在会返回null值，false时则抛出异常*/
    public String getText(introw, String ignoreCaseRowName, boolean IgnoreUnmatchedColumn) {int colIndex = -1;for(int i=0;i<this.MaxCol;i++){if(this.data.get(i).equalsIgnoreCase(ignoreCaseRowName)){

                colIndex= i+1;break;

            }

        }if(colIndex== -1 &&IgnoreUnmatchedColumn)return null;if(colIndex == -1)throw new RuntimeException("未找到符合["+ignoreCaseRowName+"]的列");returngetText(row,colIndex);

    }public String getText(int row, intcol) {int Number = (row - 1) * this.MaxCol + col - 1;if (Number <= this.MaxNumber) {return (String)this.data.get(Number + this.MaxCol);

        }else{

            log.error("指定的位置在结果集中没有数据");return null;

        }

    }public void replaceText(int row, intcol, String text) {int Number = (row - 1) * this.MaxCol + col - 1;if (Number <= this.MaxNumber) {this.data.set(Number, text);

        }else{

            log.error("指定的位置在结果集中没有数据");

        }

    }public intgetMaxCol() {return this.MaxCol;

    }public intgetMaxRow() {return this.MaxRow;

    }publicString[] getColNames(){

        String[] colNames= newString[MaxCol];for(int i=0;i<colNames.length;i++){

            colNames[i]= this.data.get(i);

        }returncolNames;

    }public String getColName(intindex) {if (index > 0 && index <= this.MaxCol) {return (String)this.data.get(index - 1);

        }else{

            log.error("指定的位置在结果集中没有数据");return null;

        }

    }public boolean setColName(intindex, String columnName) {if (index > 0 && index <= this.MaxCol) {this.data.set(index - 1, columnName);return true;

        }else{return false;

        }

    }public String[] getRowData(introw) {if (row > 0 && row <= this.MaxRow) {

            String[] result= new String[this.MaxCol];for(int i = 0; i < this.MaxCol; ++i) {int index = this.MaxCol * row +i;

                result[i]= (String)this.data.get(index);

            }returnresult;

        }else{return new String[0];

        }

    }public Map<String,String> getRowMap(introw){

        Map<String,String> data = new IgnoreCaseHashMap<>();

        String[] colNames=getColNames();for(int i=0;i<colNames.length;i++){

            data.put(colNames[i],getText(row,i+1));

        }returndata;

    }public String[] getColData(intcol) {if (col > 0 && col <= this.MaxCol) {

            String[] result= new String[this.MaxRow];for(int i = 0; i < this.MaxRow; ++i) {int index = this.MaxRow * (i + 1) +col;

                result[i]= (String)this.data.get(index);

            }returnresult;

        }else{return new String[0];

        }

    }public voidsetJdbcTypes(JdbcType[] jdbcTypes) {this.jdbcTypes =jdbcTypes;

    }public JdbcType getJdbcType(intcol) {return this.jdbcTypes[col - 1];

    }publicString toString() {

        StringBuilder builder= new StringBuilder("Grid{[");for(int i = 0; i < this.data.size(); ++i) {if (i != 0 && i % this.MaxCol == 0) {

                builder.append("],[");

            }else if (i != 0) {

                builder.append(",");

            }



            builder.append((String)this.data.get(i));

        }



        builder.append("]}");returnbuilder.toString();

    }







}

import com.sinosoft.mybatis.typehandler.DateTypeHandler;

import com.sinosoft.mybatis.typehandler.DoubleTypeHandler;

import org.apache.ibatis.cursor.Cursor;

import org.apache.ibatis.executor.resultset.ResultSetHandler;

import org.apache.ibatis.type.JdbcType;

import org.apache.ibatis.type.MappedTypes;

import org.apache.ibatis.type.TypeHandler;

import org.apache.ibatis.type.TypeHandlerRegistry;

import org.springframework.stereotype.Component;



import java.sql.*;

import java.util.Collections;

import java.util.List;



@Component

@Intercepts({

        @Signature(type= ResultSetHandler.class, method="handleResultSets", args={Statement.class}),

        @Signature(type= ResultSetHandler.class, method="handleCursorResultSets", args={Statement.class}),

        @Signature(type= ResultSetHandler.class, method="handleOutputParameters", args={CallableStatement.class})

})public classGridResultSetHandler implements ResultSetHandler {privateTypeHandlerRegistry registry;publicGridResultSetHandler(){

        registry= newTypeHandlerRegistry();

        registry.register(String.class,JdbcType.TIMESTAMP, newDateTypeHandler());

        registry.register(String.class,JdbcType.DATE, newDateTypeHandler());

        registry.register(String.class,JdbcType.NUMERIC, newDoubleTypeHandler());

        registry.register(String.class,JdbcType.DOUBLE, newDoubleTypeHandler());

    }public List<Grid>handleResultSets(Statement statement) throws SQLException {

        ResultSet resultSet=statement.getResultSet();try{

            ResultSetMetaData metaData=resultSet.getMetaData();int columnCount =metaData.getColumnCount();

            Grid grid= newGrid(columnCount);

            JdbcType[] jdbcTypes= newJdbcType[columnCount];inti;for(i = 1; i <= columnCount; ++i) {

                grid.addText(metaData.getColumnName(i));

                jdbcTypes[i- 1] =JdbcType.forCode(metaData.getColumnType(i));

            }



            grid.setJdbcTypes(jdbcTypes);



            label61:while(true) {if(resultSet.next()) {

                    i= 1;while(true) {if (i >columnCount) {continuelabel61;

                        }int columnType =metaData.getColumnType(i);

                        TypeHandler<String> typeHandler = this.registry.getTypeHandler(String.class, JdbcType.forCode(columnType));

                        grid.addText((String)typeHandler.getResult(resultSet, i));++i;

                    }

                }



                List<Grid> matrices =Collections.singletonList(grid);

                List var8=matrices;returnvar8;

            }

        }finally{

            resultSet.close();

        }

    }public Cursor<Grid>handleCursorResultSets(Statement statement) throws SQLException {throw new UnsupportedOperationException("Unsupported");

    }public voidhandleOutputParameters(CallableStatement callableStatement) throws SQLException {throw new UnsupportedOperationException("Unsupported");

    }

}

@Autowired
private SQLMapper cSQLMapper;

public void test(){


cSQLMapper.execSQLBindVariable("select * from Code where codeType=#{codeType}","sex");

Map<String,Object> bind = new HashMap<>();
bind.put("codeType","sex");
bind.put("code","1");
cSQLMapper.execSQLBindVariables("select * from Code where codeType=#{codeType} and code=#{code}",bind);

LDCodePo tLDCodePo = new LDCodePo();
tLDCodePo.setCodeType("sex");
tLDCodePo.setCode("1");
cSQLMapper.execSQLBindVariables("select * from Code where codeType=#{codetype} and code=#{code}",
new ObjectBingVariables(tLDCodePo));
}

var service = newTcpService();

service.Connecting= (client, e) => { return EasyTask.CompletedTask; };//有客户端正在连接
service.Connected = (client, e) => { return EasyTask.CompletedTask; };//有客户端成功连接
service.Disconnecting = (client, e) => { return EasyTask.CompletedTask; };//有客户端正在断开连接，只有当主动断开时才有效。
service.Disconnected = (client, e) => { return EasyTask.CompletedTask; };//有客户端断开连接
service.Received = (client, e) =>{//从客户端收到信息
    var mes = Encoding.UTF8.GetString(e.ByteBlock.Buffer, 0, e.ByteBlock.Len);//注意：数据长度是byteBlock.Len
    client.Logger.Info($"已从{client.Id}接收到信息：{mes}");

​

    client.Send(mes);//将收到的信息直接返回给发送方
​//client.Send("id",mes);//将收到的信息返回给特定ID的客户端
​//将收到的信息返回给在线的所有客户端。//注意：这里只是一个建议思路，实际上群发应该使用生产者消费者模式设计//var ids = service.GetIds();//foreach (var clientId in ids)//{//if (clientId != client.Id)//不给自己发//{//service.Send(clientId, mes);//}//}
​returnEasyTask.CompletedTask;

};

​

service.Setup(new TouchSocketConfig()//载入配置
    .SetListenIPHosts("tcp://127.0.0.1:7789", 7790)//同时监听两个地址
    .ConfigureContainer(a =>//容器的配置顺序应该在最前面
{

        a.AddConsoleLogger();//添加一个控制台日志注入（注意：在maui中控制台日志不可用）
})

    .ConfigurePlugins(a=>{//a.Add();//此处可以添加插件
}));

​

service.Start();//启动

var tcpClient = newTcpClient();

tcpClient.Connecting= (client, e) => { return EasyTask.CompletedTask; };//即将连接到服务器，此时已经创建socket，但是还未建立tcp
tcpClient.Connected = (client, e) => {return EasyTask.CompletedTask; };//成功连接到服务器
tcpClient.Disconnecting = (client, e) => {return EasyTask.CompletedTask; };//即将从服务器断开连接。此处仅主动断开才有效。
tcpClient.Disconnected = (client, e) => {return EasyTask.CompletedTask; };//从服务器断开连接，当连接不成功时不会触发。
tcpClient.Received = (client, e) =>{//从服务器收到信息。但是一般byteBlock和requestInfo会根据适配器呈现不同的值。
    var mes = Encoding.UTF8.GetString(e.ByteBlock.Buffer, 0, e.ByteBlock.Len);

    tcpClient.Logger.Info($"客户端接收到信息：{mes}");returnEasyTask.CompletedTask;

};

​//载入配置
tcpClient.Setup(newTouchSocketConfig()

    .SetRemoteIPHost("127.0.0.1:7789")

    .ConfigureContainer(a=>{

        a.AddConsoleLogger();//添加一个日志注入
}));

​

tcpClient.Connect();//调用连接，当连接不成功时，会抛出异常。
​//Result result = tcpClient.TryConnect();//或者可以调用TryConnect//if (result.IsSuccess())//{
​//}
​

tcpClient.Logger.Info("客户端成功连接");

​

tcpClient.Send("RRQM");

.ConfigurePlugins(a=>{

   a.UseReconnection(5, true, 1000);//如需永远尝试连接，tryCount设置为-1即可。
});