Functions — github.com/alchemystar/Lancelot

hub / github.com/alchemystar/Lancelot / functions

Functions605 in github.com/alchemystar/Lancelot

⨍ Functions 605◇ Types & classes 118

↓ 204 callersMethodlength

()

src/main/java/alchemystar/lancelot/common/net/proto/mysql/MySQLMessage.java:31

↓ 42 callersMethodgetBytes

(long i, int index, byte[] buf)

src/main/java/alchemystar/lancelot/common/net/proto/util/LongUtil.java:34

↓ 36 callersMethodadd

(byte[] value)

src/main/java/alchemystar/lancelot/common/net/proto/mysql/RowDataPacket.java:30

↓ 28 callersMethodread

(int i)

src/main/java/alchemystar/lancelot/common/net/proto/mysql/MySQLMessage.java:55

↓ 25 callersMethodgetCtx

()

src/main/java/alchemystar/lancelot/common/net/handler/session/FrontendSession.java:174

↓ 24 callersMethodwriteErrMessage

(int errno, String msg)

src/main/java/alchemystar/lancelot/common/net/handler/frontend/FrontendConnection.java:167

↓ 20 callersMethodgetSource

取得源端连接

src/main/java/alchemystar/lancelot/common/net/handler/session/Session.java:16

↓ 17 callersMethodisEOF

(char c)

src/main/java/alchemystar/lancelot/parser/util/ParseUtil.java:13

↓ 17 callersMethodwriteBuf

(ByteBuf buffer,ChannelHandlerContext ctx)

src/main/java/alchemystar/lancelot/common/net/proto/MySQLPacket.java:190

↓ 15 callersMethodgetLength

(long length)

src/main/java/alchemystar/lancelot/common/net/proto/util/BufferUtil.java:103

↓ 15 callersMethodwriteOk

()

src/main/java/alchemystar/lancelot/common/net/handler/frontend/FrontendConnection.java:146

↓ 14 callersMethodformat

日期对象解析成日期字符串基础方法，可以据此封装出多种便捷的方法直接使用 @param date 待格式化的日期对象 @param format 输出的格式 @return 格式化的字符串

src/main/java/alchemystar/lancelot/route/util/DateUtil.java:51

↓ 14 callersMethodreadUB2

()

src/main/java/alchemystar/lancelot/common/net/proto/mysql/MySQLMessage.java:63

↓ 14 callersMethodwrite

把数据包写到buffer中，如果buffer满了就把buffer通过前端连接写出。

src/main/java/alchemystar/lancelot/common/net/proto/MySQLPacket.java:179

↓ 14 callersMethodwriteUB3

(ByteBuf buffer, int i)

src/main/java/alchemystar/lancelot/common/net/proto/util/BufferUtil.java:19

↓ 13 callersMethodrelease

()

src/main/java/alchemystar/lancelot/common/net/handler/session/FrontendSession.java:151

↓ 11 callersMethodisAutocommit

()

src/main/java/alchemystar/lancelot/common/net/handler/frontend/FrontendConnection.java:338

↓ 11 callersMethodpostCommand

(Command command)

src/main/java/alchemystar/lancelot/common/net/handler/backend/BackendConnection.java:69

↓ 11 callersMethodtoString

()

src/main/java/alchemystar/lancelot/loader/TableRuleConfig.java:50

↓ 11 callersMethodtoString

()

src/main/java/alchemystar/lancelot/common/net/proto/MySQLPacket.java:204

↓ 11 callersMethodwriteUB2

(ByteBuf buffer, int i)

src/main/java/alchemystar/lancelot/common/net/proto/util/BufferUtil.java:14

↓ 10 callersMethodreadBytesWithLength

()

src/main/java/alchemystar/lancelot/common/net/proto/mysql/MySQLMessage.java:179

↓ 10 callersMethodtoString

(byte[] bytes)

src/main/java/alchemystar/lancelot/common/net/proto/util/StringUtil.java:326

↓ 10 callersMethodwriteWithLength

(ByteBuf buffer, byte[] src)

src/main/java/alchemystar/lancelot/common/net/proto/util/BufferUtil.java:78

↓ 9 callersMethodclose

关闭会话，必须在关闭源端连接后执行该方法。

src/main/java/alchemystar/lancelot/common/net/handler/session/Session.java:52

↓ 9 callersMethodgetName

()

src/main/java/alchemystar/lancelot/common/net/route/RouteResultsetNode.java:28

↓ 9 callersMethodmove

(String stmt, int offset, int length)

src/main/java/alchemystar/lancelot/parser/util/ParseUtil.java:288

↓ 9 callersMethodwrite

(ChannelHandlerContext ctx)

src/main/java/alchemystar/lancelot/common/net/proto/mysql/OkPacket.java:45

↓ 9 callersMethodwriteBuf

(ByteBuf buffer,ChannelHandlerContext ctx)

src/main/java/alchemystar/lancelot/common/net/proto/mysql/EOFPacket.java:42

↓ 8 callersMethodcomment

(String stmt, int offset)

src/main/java/alchemystar/lancelot/parser/util/ParseUtil.java:165

↓ 8 callersMethodgetTarget

(RouteResultsetNode key)

src/main/java/alchemystar/lancelot/common/net/handler/session/FrontendSession.java:142

↓ 8 callersMethodread

(BinaryPacket bin)

src/main/java/alchemystar/lancelot/common/net/proto/mysql/ErrorPacket.java:26

↓ 8 callersMethodreadLength

()

src/main/java/alchemystar/lancelot/common/net/proto/mysql/MySQLMessage.java:117

↓ 7 callersMethoddecrementCountBy

()

src/main/java/alchemystar/lancelot/common/net/handler/node/MultiNodeHandler.java:44

↓ 7 callersMethodexecute

开启一个会话执行

src/main/java/alchemystar/lancelot/common/net/handler/session/Session.java:26

↓ 7 callersMethodfireCmd

()

src/main/java/alchemystar/lancelot/common/net/handler/backend/BackendConnection.java:47

↓ 7 callersMethodgetField

(String name, String orgName, int type)

src/main/java/alchemystar/lancelot/common/net/proto/util/PacketUtil.java:39

↓ 7 callersMethodgetHeader

(int fieldCount)

src/main/java/alchemystar/lancelot/common/net/proto/util/PacketUtil.java:21

↓ 7 callersMethodgetNodes

()

src/main/java/alchemystar/lancelot/common/net/route/RouteResultset.java:41

↓ 7 callersMethodposition

()

src/main/java/alchemystar/lancelot/common/net/proto/mysql/MySQLMessage.java:35

↓ 7 callersMethodreadUB3

()

src/main/java/alchemystar/lancelot/common/net/proto/mysql/MySQLMessage.java:70

↓ 7 callersMethodwriteBuf

(ByteBuf buffer,ChannelHandlerContext ctx)

src/main/java/alchemystar/lancelot/common/net/proto/mysql/RowDataPacket.java:60

↓ 7 callersMethodwriteWithNull

(ByteBuf buffer, byte[] src)

src/main/java/alchemystar/lancelot/common/net/proto/util/BufferUtil.java:73

↓ 6 callersMethodequals

(String str1, String str2)

src/main/java/alchemystar/lancelot/common/net/proto/util/ArrayUtil.java:11

↓ 6 callersMethodgetCharset

(int index)

src/main/java/alchemystar/lancelot/common/net/proto/util/CharsetUtil.java:121

↓ 6 callersMethodgetId

()

src/main/java/alchemystar/lancelot/common/net/handler/frontend/FrontendConnection.java:346

↓ 6 callersMethodgetResponseHandler

()

src/main/java/alchemystar/lancelot/common/net/handler/backend/BackendCommandHandler.java:181

↓ 6 callersMethodhasRemaining

()

src/main/java/alchemystar/lancelot/common/net/proto/mysql/MySQLMessage.java:51

↓ 6 callersMethodisEmpty

(String str)

src/main/java/alchemystar/lancelot/common/net/proto/util/StringUtil.java:88

↓ 6 callersMethodreadBytes

()

src/main/java/alchemystar/lancelot/common/net/proto/mysql/MySQLMessage.java:133

↓ 6 callersMethodwriteErrMessage

(int errno, String msg)

src/main/java/alchemystar/lancelot/common/net/handler/node/CommitExecutor.java:144

↓ 6 callersMethodwriteLength

(ByteBuf buffer, long l)

src/main/java/alchemystar/lancelot/common/net/proto/util/BufferUtil.java:58

↓ 6 callersMethodwriteUB4

(ByteBuf buffer, long l)

src/main/java/alchemystar/lancelot/common/net/proto/util/BufferUtil.java:36

↓ 5 callersMethodreadUB4

()

src/main/java/alchemystar/lancelot/common/net/proto/mysql/MySQLMessage.java:78

↓ 5 callersMethodreset

(int initCount)

src/main/java/alchemystar/lancelot/common/net/handler/node/MultiNodeHandler.java:57

↓ 5 callersMethodsetTxIsolation

(int txIsolation)

src/main/java/alchemystar/lancelot/common/net/handler/frontend/FrontendConnection.java:334

↓ 5 callersMethodsplit

(String src)

src/main/java/alchemystar/lancelot/common/net/proto/util/SplitUtil.java:49

↓ 5 callersMethodwriteOk

()

src/main/java/alchemystar/lancelot/common/net/handler/node/CommitExecutor.java:149

↓ 4 callersMethodcommit

提交一个会话执行

src/main/java/alchemystar/lancelot/common/net/handler/session/Session.java:31

↓ 4 callersMethodcompare

(String s, int offset, char[] keyword)

src/main/java/alchemystar/lancelot/parser/util/ParseUtil.java:308

↓ 4 callersMethodencode

(String src, String charset)

src/main/java/alchemystar/lancelot/common/net/proto/util/PacketUtil.java:28

↓ 4 callersMethodequalsIgnoreCase

(String str1, String str2)

src/main/java/alchemystar/lancelot/common/net/proto/util/StringUtil.java:337

↓ 4 callersMethodgetIndex

(String charset)

src/main/java/alchemystar/lancelot/common/net/proto/util/CharsetUtil.java:125

↓ 4 callersMethodgetTargetCount

取得当前目标端数量

src/main/java/alchemystar/lancelot/common/net/handler/session/Session.java:21

↓ 4 callersMethodmove

(int i)

src/main/java/alchemystar/lancelot/common/net/proto/mysql/MySQLMessage.java:43

↓ 4 callersMethodreplace

(String text, String repl, String with)

src/main/java/alchemystar/lancelot/common/net/proto/util/StringUtil.java:361

↓ 4 callersMethodsetCharset

(String charset, FrontendConnection c)

src/main/java/alchemystar/lancelot/common/net/response/CharacterSet.java:118

↓ 4 callersMethodsetLastInsertId

(long lastInsertId)

src/main/java/alchemystar/lancelot/common/net/handler/frontend/FrontendConnection.java:322

↓ 4 callersMethodsetNodes

(RouteResultsetNode[] nodes)

src/main/java/alchemystar/lancelot/common/net/route/RouteResultset.java:45

↓ 4 callersMethodskipAs

<code>SELECT LAST_INSERT_ID() AS id</code> @param offset index of first ' ' after LAST_INSERT_ID(), offset == stmt.length() is

src/main/java/alchemystar/lancelot/parser/ServerParseSelect.java:259

↓ 4 callersMethodsubstrings

取指定字符串的子串，新增对中文字符串的支持注意方法名称为<code>substring<b>s</b></code> @param str 字符串 @param start 起始索引，如果为负数，表示从尾部计算 @param end 结束索引（不含），如果为负数，表示从尾部计算 @return

src/main/java/alchemystar/lancelot/route/util/StringUtil.java:146

↓ 4 callersMethodwrite

(ChannelHandlerContext ctx)

src/main/java/alchemystar/lancelot/common/net/proto/mysql/ErrorPacket.java:52

↓ 3 callersMethodaddToFieldList

(BinaryPacket bin)

src/main/java/alchemystar/lancelot/common/net/handler/backend/BackendCommandHandler.java:137

↓ 3 callersMethodcurrentCharIsSep

(String stmt, int offset)

src/main/java/alchemystar/lancelot/parser/util/ParseUtil.java:188

↓ 3 callersMethodencode

(String src, String charset)

src/main/java/alchemystar/lancelot/common/net/proto/util/StringUtil.java:47

↓ 3 callersMethodgetBackendCommand

(CommandPacket packet, int sqlType)

src/main/java/alchemystar/lancelot/common/net/handler/frontend/AbstractFrontendConnection.java:60

↓ 3 callersMethodgetCoreSize

()

src/main/java/alchemystar/lancelot/common/threadpool/config/ThreadPoolConfig.java:41

↓ 3 callersMethodgetLocalCalendar

()

src/main/java/alchemystar/lancelot/common/net/proto/mysql/MySQLMessage.java:325

↓ 3 callersMethodgetName

()

src/main/java/alchemystar/lancelot/common/threadpool/config/ThreadPoolConfig.java:33

↓ 3 callersMethodgetQueues

()

src/main/java/alchemystar/lancelot/common/threadpool/config/ThreadPoolConfig.java:57

↓ 3 callersMethodgetSchema

()

src/main/java/alchemystar/lancelot/common/net/handler/frontend/FrontendConnection.java:302

↓ 3 callersMethodgetSource

()

src/main/java/alchemystar/lancelot/common/net/handler/backend/BackendHeadHandler.java:23

↓ 3 callersMethodgetSqlType

()

src/main/java/alchemystar/lancelot/common/net/handler/backend/cmd/Command.java:53

↓ 3 callersMethodisIdentifierChar

(char c)

src/main/java/alchemystar/lancelot/parser/util/CharTypes.java:49

↓ 3 callersMethodnotifyFailure

()

src/main/java/alchemystar/lancelot/common/net/handler/node/MultiNodeExecutor.java:182

↓ 3 callersMethodputBackend

(BackendConnection backend)

src/main/java/alchemystar/lancelot/common/net/handler/backend/pool/MySqlDataPool.java:187

↓ 3 callersMethodread

把字节数组转变成FieldPacket

src/main/java/alchemystar/lancelot/common/net/proto/mysql/FieldPacket.java:38

↓ 3 callersMethodread

(BinaryPacket bin)

src/main/java/alchemystar/lancelot/common/net/proto/mysql/OkPacket.java:31

↓ 3 callersMethodreadBytesWithNull

()

src/main/java/alchemystar/lancelot/common/net/proto/mysql/MySQLMessage.java:150

↓ 3 callersMethodrecycle

(BackendConnection backend)

src/main/java/alchemystar/lancelot/common/net/handler/backend/pool/MySqlDataPool.java:178

↓ 3 callersMethodrollback

回滚一个会话执行

src/main/java/alchemystar/lancelot/common/net/handler/session/Session.java:36

↓ 3 callersMethodselectStateStep

()

src/main/java/alchemystar/lancelot/common/net/handler/backend/BackendCommandHandler.java:148

↓ 3 callersMethodsetFailed

(String errorMessage,int errno)

src/main/java/alchemystar/lancelot/common/net/handler/node/MultiNodeHandler.java:66

↓ 3 callersMethodsetName

(String name)

src/main/java/alchemystar/lancelot/common/threadpool/config/ThreadPoolConfig.java:37

↓ 3 callersMethodsetTxInterrupt

设置是否需要中断当前事务

src/main/java/alchemystar/lancelot/common/net/handler/session/FrontendSession.java:163

↓ 3 callersMethodwriteLong

(ByteBuf buffer, long l)

src/main/java/alchemystar/lancelot/common/net/proto/util/BufferUtil.java:43

↓ 2 callersMethodcalcPacketSize

()

src/main/java/alchemystar/lancelot/common/net/proto/mysql/AuthPacket.java:113

↓ 2 callersMethodcalcPacketSize

()

src/main/java/alchemystar/lancelot/common/net/proto/mysql/FieldPacket.java:63

↓ 2 callersMethodcalcPacketSize

()

src/main/java/alchemystar/lancelot/common/net/proto/mysql/RowDataPacket.java:76

↓ 2 callersMethodcontains

(String column)

src/main/java/alchemystar/lancelot/loader/TableRuleConfig.java:25

next →1–100 of 605, ranked by callers