MCPcopy Create free account

hub / github.com/alchemystar/Lancelot / functions

Functions605 in github.com/alchemystar/Lancelot

MethodServerQueryHandler
(FrontendConnection source)
src/main/java/alchemystar/lancelot/common/net/handler/frontend/ServerQueryHandler.java:23
MethodSingleNodeExecutor
(FrontendSession session)
src/main/java/alchemystar/lancelot/common/net/handler/node/SingleNodeExecutor.java:26
MethodTableRuleConfig
(String[] columns, String tableName, String dbRender, String tbRender)
src/main/java/alchemystar/lancelot/loader/TableRuleConfig.java:18
MethodUnknownCharsetException
()
src/main/java/alchemystar/lancelot/common/net/exception/UnknownCharsetException.java:14
MethodUnknownDataNodeException
()
src/main/java/alchemystar/lancelot/common/net/exception/UnknownDataNodeException.java:12
MethodUnknownPacketException
()
src/main/java/alchemystar/lancelot/common/net/exception/UnknownPacketException.java:14
MethodUnknownTxIsolationException
()
src/main/java/alchemystar/lancelot/common/net/exception/UnknownTxIsolationException.java:14
MethodaddCurMin
平移当前时间,以分为单元,minutes @param minutes @return
src/main/java/alchemystar/lancelot/route/util/DateUtil.java:230
MethodaddCurSeconds
平移当前时间,以秒为单元,minutes @param secs @return
src/main/java/alchemystar/lancelot/route/util/DateUtil.java:240
MethodalignLefts
扩展并左对齐字符串,用指定字符串填充右边。 新增对中文字符串的支持,注意方法名称为<code>alignLeft<b>s</b></code> <pre> StringUtil.alignLeft(null, , ) = null StringUtil.alignLeft("", 3,
src/main/java/alchemystar/lancelot/route/util/StringUtil.java:54
MethodalignRights
扩展并右对齐字符串,用指定字符串填充左边。 新增对中文字符串的支持,注意方法名称为<code>alignRight<b>s</b></code> <pre> StringUtil.alignRight(null, , ) = null StringUtil.alignRight("",
src/main/java/alchemystar/lancelot/route/util/StringUtil.java:107
MethodcalcPacketSize
计算数据包大小,不包含包头长度。
src/main/java/alchemystar/lancelot/common/net/proto/MySQLPacket.java:197
MethodcalcPacketSize
()
src/main/java/alchemystar/lancelot/common/net/proto/mysql/BinaryPacket.java:27
Methodcancel
取消一个正在执行中的会话 @param sponsor
src/main/java/alchemystar/lancelot/common/net/handler/session/Session.java:43
Methodcancel
(FrontendConnection sponsor)
src/main/java/alchemystar/lancelot/common/net/handler/session/FrontendSession.java:113
MethodchannelActive
(ChannelHandlerContext ctx)
src/main/java/alchemystar/lancelot/common/net/handler/frontend/FrontendGroupHandler.java:34
MethodchannelActive
发送握手包 @param ctx @throws Exception
src/main/java/alchemystar/lancelot/common/net/handler/frontend/FrontendAuthenticator.java:48
MethodchannelInactive
(ChannelHandlerContext ctx)
src/main/java/alchemystar/lancelot/common/net/handler/frontend/FrontendGroupHandler.java:40
MethodchannelRead
(ChannelHandlerContext ctx, Object msg)
src/main/java/alchemystar/lancelot/common/net/handler/frontend/FrontendCommandHandler.java:30
MethodchannelRead
(ChannelHandlerContext ctx, Object msg)
src/main/java/alchemystar/lancelot/common/net/handler/frontend/FrontendAuthenticator.java:76
MethodchannelRead
(ChannelHandlerContext ctx, Object msg)
src/main/java/alchemystar/lancelot/common/net/handler/backend/BackendAuthenticator.java:48
MethodchannelRead
(ChannelHandlerContext ctx, Object msg)
src/main/java/alchemystar/lancelot/common/net/handler/backend/BackendCommandHandler.java:50
Methodclose
()
src/main/java/alchemystar/lancelot/common/net/handler/session/FrontendSession.java:121
Methodcommit
提交事务
src/main/java/alchemystar/lancelot/common/net/handler/frontend/FrontendConnection.java:218
Methodcommit
()
src/main/java/alchemystar/lancelot/common/net/handler/session/FrontendSession.java:96
Methodcommit
()
src/main/java/alchemystar/lancelot/common/net/handler/node/CommitExecutor.java:38
Methodcontains
(String[] list, String str)
src/main/java/alchemystar/lancelot/common/net/proto/util/ArrayUtil.java:18
MethodcountChar
(String str, char c)
src/main/java/alchemystar/lancelot/common/net/proto/util/StringUtil.java:344
MethodcountDown
()
src/main/java/alchemystar/lancelot/common/net/handler/backend/BackendConnection.java:102
MethodcutString
根据长度<code>length</code>把字符串切成两段,保存数组<br> 确保中文不要被切成两半 @param message @param length @return
src/main/java/alchemystar/lancelot/route/util/StringUtil.java:166
Methoddecode
(byte[] src, String charset)
src/main/java/alchemystar/lancelot/common/net/proto/util/StringUtil.java:58
Methoddecode
MySql外层结构解包 @param ctx @param in @param out @throws Exception
src/main/java/alchemystar/lancelot/common/net/codec/MySqlPacketDecoder.java:38
MethoddecodeLength
(byte[] src)
src/main/java/alchemystar/lancelot/common/net/proto/util/ByteUtil.java:68
MethoddecrementCountToZero
()
src/main/java/alchemystar/lancelot/common/net/handler/node/MultiNodeHandler.java:33
Methoddiscard
()
src/main/java/alchemystar/lancelot/common/net/handler/backend/BackendConnection.java:96
MethoddumpAsHex
(byte[] src, int length)
src/main/java/alchemystar/lancelot/common/net/proto/util/StringUtil.java:229
Methodequals
(Object obj)
src/main/java/alchemystar/lancelot/common/net/route/RouteResultsetNode.java:40
MethoderrorResponse
(BinaryPacket bin)
src/main/java/alchemystar/lancelot/common/net/handler/node/RollBackExecutor.java:57
MethoderrorResponse
(BinaryPacket bin)
src/main/java/alchemystar/lancelot/common/net/handler/node/SingleNodeExecutor.java:59
MethoderrorResponse
(BinaryPacket bin)
src/main/java/alchemystar/lancelot/common/net/handler/node/MultiNodeExecutor.java:94
MethoderrorResponse
(BinaryPacket bin)
src/main/java/alchemystar/lancelot/common/net/handler/node/CommitExecutor.java:65
MethodescapeEasternUnicodeByteStream
(byte[] src, String srcString, int offset, int length)
src/main/java/alchemystar/lancelot/common/net/proto/util/StringUtil.java:278
MethodexceptionCaught
(ChannelHandlerContext ctx, Throwable cause)
src/main/java/alchemystar/lancelot/common/net/handler/frontend/FrontendTailHandler.java:27
MethodexceptionCaught
(ChannelHandlerContext ctx, Throwable cause)
src/main/java/alchemystar/lancelot/common/net/handler/backend/BackendTailHandler.java:26
Methodexecute
(String sql, int type)
src/main/java/alchemystar/lancelot/common/net/handler/frontend/FrontendConnection.java:250
Methodexecute
(String sql, int type)
src/main/java/alchemystar/lancelot/common/net/handler/session/FrontendSession.java:65
Methodexecute
(RouteResultset rrs)
src/main/java/alchemystar/lancelot/common/net/handler/node/RollBackExecutor.java:159
Methodexecute
(RouteResultset rrs)
src/main/java/alchemystar/lancelot/common/net/handler/node/SingleNodeExecutor.java:30
Methodexecute
异步执行 todo 如果要做连接数限流的话,backend.recycle的时候在lastEof获取的时候,执行 的时候需要加锁,来限制并发
src/main/java/alchemystar/lancelot/common/net/handler/node/MultiNodeExecutor.java:46
Methodexecute
(RouteResultset rrs)
src/main/java/alchemystar/lancelot/common/net/handler/node/ResponseHandler.java:18
Methodexecute
(RouteResultset rrs)
src/main/java/alchemystar/lancelot/common/net/handler/node/CommitExecutor.java:161
MethodfieldListResponse
(List<BinaryPacket> fieldList)
src/main/java/alchemystar/lancelot/common/net/handler/node/RollBackExecutor.java:163
MethodfieldListResponse
(List<BinaryPacket> fieldList)
src/main/java/alchemystar/lancelot/common/net/handler/node/SingleNodeExecutor.java:48
MethodfieldListResponse
(List<BinaryPacket> fieldList)
src/main/java/alchemystar/lancelot/common/net/handler/node/MultiNodeExecutor.java:70
MethodfieldListResponse
(List<BinaryPacket> fieldList)
src/main/java/alchemystar/lancelot/common/net/handler/node/CommitExecutor.java:165
Methodfilter
(String text)
src/main/java/alchemystar/lancelot/loader/ConfigUtil.java:20
MethodfilterJsonString
过滤要输出到json的字符串,将'和"进行转义输出 @param input @return
src/main/java/alchemystar/lancelot/route/util/StringUtil.java:249
MethodfilterXMLString
过滤要输出到xml的字符串,将<,>,&,"进行转义输出 @param string @return
src/main/java/alchemystar/lancelot/route/util/StringUtil.java:279
MethodformatMonth
把日期对象按照<code>yyyyMM</code>格式解析成字符串 @param date 待格式化的日期对象 @return 格式化的字符串
src/main/java/alchemystar/lancelot/route/util/DateUtil.java:158
MethodformatNumberToFixedLength
将数字格式化到固定长度 @param input @param fixLength @return
src/main/java/alchemystar/lancelot/route/util/StringUtil.java:388
MethodformatShort
把日期对象按照<code>yyyyMMdd</code>格式解析成字符串 @param date 待格式化的日期对象 @return 格式化的字符串
src/main/java/alchemystar/lancelot/route/util/DateUtil.java:115
MethodformatTime
把日期对象按照<code>HHmmss</code>格式解析成字符串 @param date 待格式化的日期对象 @return 格式化的字符串
src/main/java/alchemystar/lancelot/route/util/DateUtil.java:169
MethodformatWeb
把日期对象按照<code>yyyy-MM-dd</code>格式解析成字符串 @param date 待格式化的日期对象 @return 格式化的字符串
src/main/java/alchemystar/lancelot/route/util/DateUtil.java:136
MethodgenSerialNo
生成一定长度的序列号 @param length @param padding @return
src/main/java/alchemystar/lancelot/route/util/StringUtil.java:371
MethodgetAffectedRows
()
src/main/java/alchemystar/lancelot/common/net/handler/node/MultiNodeExecutor.java:202
MethodgetAuthTimeout
()
src/main/java/alchemystar/lancelot/common/net/handler/frontend/FrontendConnection.java:326
MethodgetBackend
()
src/main/java/alchemystar/lancelot/common/net/handler/backend/pool/MySqlDataSource.java:21
MethodgetCharset
()
src/main/java/alchemystar/lancelot/common/net/handler/frontend/FrontendConnection.java:259
MethodgetCharset
()
src/main/java/alchemystar/lancelot/common/net/handler/backend/BackendConnection.java:119
MethodgetCharsetIndex
()
src/main/java/alchemystar/lancelot/common/net/handler/frontend/FrontendConnection.java:186
MethodgetCharsetIndex
()
src/main/java/alchemystar/lancelot/common/net/handler/backend/BackendConnection.java:111
MethodgetCmdPacket
()
src/main/java/alchemystar/lancelot/common/net/handler/backend/cmd/Command.java:37
MethodgetCode
()
src/main/java/alchemystar/lancelot/common/net/handler/backend/cmd/CmdType.java:24
MethodgetColumns
()
src/main/java/alchemystar/lancelot/loader/TableRuleConfig.java:34
MethodgetConnection
()
src/main/java/alchemystar/lancelot/common/net/handler/factory/BackendConnectionFactory.java:22
MethodgetDataSource
()
src/main/java/alchemystar/lancelot/common/net/handler/frontend/FrontendConnection.java:354
MethodgetExecutor
默认的线程池配置 核心16个 最大线程32个 排队数量128个 保活时间60s @return
src/main/java/alchemystar/lancelot/common/threadpool/AbstractThreadPool.java:22
MethodgetExecutor
(ThreadPoolConfig threadPoolConfig)
src/main/java/alchemystar/lancelot/common/threadpool/limited/LimitedThreadPool.java:24
MethodgetExecutor
(ThreadPoolConfig config)
src/main/java/alchemystar/lancelot/common/threadpool/fixed/FixedThreadPool.java:24
MethodgetExecutor
(ThreadPoolConfig config)
src/main/java/alchemystar/lancelot/common/threadpool/cached/CachedThreadPool.java:24
MethodgetFrontCtx
()
src/main/java/alchemystar/lancelot/common/net/handler/backend/BackendConnection.java:65
MethodgetFrontend
()
src/main/java/alchemystar/lancelot/common/net/handler/backend/BackendConnection.java:139
MethodgetGBKByteLength
获取指定字符串按GBK编码转换成byte的长度 由于String.getByte方法依赖于操作系统编码,处理中文字符串时建议用此方法 @param data @return
src/main/java/alchemystar/lancelot/route/util/StringUtil.java:360
MethodgetId
()
src/main/java/alchemystar/lancelot/common/net/handler/backend/BackendConnection.java:123
MethodgetLastMonth
根据日期格式返回上月的日期 @param format @return
src/main/java/alchemystar/lancelot/route/util/DateUtil.java:218
MethodgetMultiNodeExecutor
()
src/main/java/alchemystar/lancelot/common/net/handler/session/FrontendSession.java:182
MethodgetNewLine
获取换行符(\n),供vm中使用,屏蔽了操作系统的差异 @return
src/main/java/alchemystar/lancelot/route/util/StringUtil.java:419
MethodgetNewString
将byte[]按指定编码转换为字符串,供velocity中使用 @param bytes @param charsetName @return
src/main/java/alchemystar/lancelot/route/util/StringUtil.java:429
MethodgetPacketHeaderSize
()
src/main/java/alchemystar/lancelot/common/net/handler/frontend/FrontendConnection.java:282
MethodgetPacketInfo
()
src/main/java/alchemystar/lancelot/common/net/proto/mysql/AuthPacket.java:122
MethodgetPacketInfo
()
src/main/java/alchemystar/lancelot/common/net/proto/mysql/FieldPacket.java:78
MethodgetPacketInfo
()
src/main/java/alchemystar/lancelot/common/net/proto/mysql/ErrorPacket.java:78
MethodgetPacketInfo
()
src/main/java/alchemystar/lancelot/common/net/proto/mysql/RowDataPacket.java:86
MethodgetPacketInfo
()
src/main/java/alchemystar/lancelot/common/net/proto/mysql/HandshakePacket.java:78
MethodgetPacketInfo
()
src/main/java/alchemystar/lancelot/common/net/proto/mysql/ResultSetHeaderPacket.java:53
MethodgetPacketInfo
()
src/main/java/alchemystar/lancelot/common/net/proto/mysql/OkPacket.java:73
MethodgetPacketInfo
()
src/main/java/alchemystar/lancelot/common/net/proto/mysql/CommandPacket.java:53
MethodgetPacketInfo
()
src/main/java/alchemystar/lancelot/common/net/proto/mysql/EOFPacket.java:62
MethodgetPacketInfo
()
src/main/java/alchemystar/lancelot/common/net/proto/mysql/BinaryPacket.java:41
MethodgetQueryHandler
()
src/main/java/alchemystar/lancelot/common/net/handler/frontend/FrontendConnection.java:274
← previousnext →401–500 of 605, ranked by callers