Functions — github.com/MyCATApache/Mycat-Server

hub / github.com/MyCATApache/Mycat-Server / functions

Functions7,572 in github.com/MyCATApache/Mycat-Server

⨍ Functions 7,572◇ Types & classes 1,168

Append a new value for the key. This method could be called multiple times for a given key. The return value indicates whether the put succeeded or wh

src/main/java/io/mycat/memory/unsafe/map/BytesToBytesMap.java:706

↓ 1,029 callersMethodget

(Object key)

src/main/java/io/mycat/cache/CachePool.java:36

↓ 777 callersMethodput

(String id, CoordinatorLogEntry coordinatorLogEntry)

src/main/java/io/mycat/backend/mysql/xa/recovery/Repository.java:14

↓ 730 callersMethodlength

()

src/main/java/io/mycat/backend/mysql/MySQLMessage.java:50

↓ 591 callersMethodsize

()

src/main/java/io/mycat/buffer/BufferPool.java:17

↓ 484 callersMethodwrite

写出一块缓存数据

src/main/java/io/mycat/net/NIOConnection.java:47

↓ 468 callersMethodfromString

Creates an UTF8String from String.

src/main/java/io/mycat/memory/unsafe/types/UTF8String.java:109

↓ 417 callersMethodadd

向堆添加元素 @param row

src/main/java/io/mycat/sqlengine/mpp/tmp/HeapItf.java:29

↓ 373 callersMethodadd

(byte[] value)

src/main/java/io/mycat/net/mysql/RowDataPacket.java:70

↓ 333 callersMethodgetField

(String name, String orgName, int type)

src/main/java/io/mycat/backend/mysql/PacketUtil.java:58

↓ 331 callersMethodgetInstance

()

src/main/java/io/mycat/MycatServer.java:152

↓ 302 callersMethoderror

(SAXParseException e)

src/main/java/io/mycat/config/util/ConfigUtil.java:105

↓ 299 callersMethodgetNodes

()

src/main/java/io/mycat/route/RouteResultset.java:294

↓ 281 callersMethodsubstring

Returns a substring of this. @param start the position of first code point @param until the position after last code point, exclusive.

src/main/java/io/mycat/memory/unsafe/types/UTF8String.java:241

↓ 271 callersMethodgetName

()

src/main/java/io/mycat/net/SocketAcceptor.java:7

↓ 239 callersMethodget

(String coordinatorId)

src/main/java/io/mycat/backend/mysql/xa/recovery/Repository.java:16

↓ 207 callersMethodget

获取sequence对应的对象 @param sequence @return

src/main/java/io/mycat/memory/unsafe/ringbuffer/common/DataProvider.java:14

↓ 205 callersMethodcurrentTimeMillis

()

src/main/java/io/mycat/util/TimeUtil.java:34

↓ 199 callersMethodtoUpperCase

Returns the upper case of this string

src/main/java/io/mycat/memory/unsafe/types/UTF8String.java:323

↓ 190 callersMethodindexOf

Returns the position of the first occurrence of substr in current string from the specified position (0-based index). @param v the string to be searc

src/main/java/io/mycat/memory/unsafe/types/UTF8String.java:546

↓ 179 callersMethodtrim

()

src/main/java/io/mycat/memory/unsafe/types/UTF8String.java:465

↓ 174 callersMethodvalueOf

(int val)

src/main/java/io/mycat/backend/postgresql/packet/PostgreSQLPacket.java:50

↓ 165 callersMethodset

Sets the value at position {@code index}.

src/main/java/io/mycat/memory/unsafe/array/LongArray.java:83

↓ 161 callersMethodencode

(String src, String charset)

src/main/java/io/mycat/util/StringUtil.java:77

↓ 161 callersMethodequalsIgnoreCase

(String str1, String str2)

src/main/java/io/mycat/util/StringUtil.java:382

↓ 160 callersMethodisEmpty

(String str)

src/main/java/io/mycat/util/StringUtil.java:120

↓ 156 callersMethodclose

关闭连接

src/main/java/io/mycat/net/ClosableConnection.java:31

↓ 153 callersMethodgetConfig

()

src/main/java/io/mycat/config/MycatNode.java:48

↓ 151 callersMethodgetSource

取得源端连接

src/main/java/io/mycat/server/Session.java:37

↓ 144 callersMethodgetKey

()

src/main/java/io/mycat/config/loader/zkprocess/comm/ZkParamCfg.java:67

↓ 137 callersMethodroute

(SystemConfig sysConfig, SchemaConfig schema, int sqlType, String realSQL, String charset, ServerConnection

src/main/java/io/mycat/catlets/Catlet.java:23

↓ 128 callersMethodallocate

(int size)

src/main/java/io/mycat/buffer/BufferPool.java:14

↓ 126 callersMethodgetCharset

()

src/main/java/io/mycat/net/ClosableConnection.java:27

↓ 124 callersMethodnext

申请下一个sequence(value)作为生产event的位置 @return sequence的value

src/main/java/io/mycat/memory/unsafe/ringbuffer/common/Sequenced.java:31

↓ 122 callersMethodequals

(Object obj)

src/main/java/io/mycat/route/parser/util/Pair.java:74

↓ 121 callersMethodparseInt

(String value)

src/main/java/io/mycat/backend/postgresql/packet/CommandComplete.java:125

↓ 117 callersMethodstartsWith

(final UTF8String prefix)

src/main/java/io/mycat/memory/unsafe/types/UTF8String.java:312

↓ 115 callersMethodgetMessage

(int index, String info)

src/main/java/io/mycat/backend/datasource/PhysicalDBPool.java:387

↓ 114 callersMethodsplit

(String src)

src/main/java/io/mycat/util/SplitUtil.java:64

↓ 113 callersMethodgetOperator

()

src/main/java/io/mycat/sqlengine/mpp/HavingCols.java:36

↓ 113 callersMethodgetRight

()

src/main/java/io/mycat/sqlengine/mpp/HavingCols.java:28

↓ 110 callersMethodgetParent

()

src/main/java/io/mycat/catlets/TableFilter.java:332

↓ 110 callersMethodtoBytes

(long i)

src/main/java/io/mycat/util/LongUtil.java:33

↓ 108 callersMethodvalues

()

src/main/java/io/mycat/config/util/OrderRetainingMap.java:50

↓ 106 callersMethodclear

()

src/main/java/io/mycat/net/handler/LoadDataInfileHandler.java:40

↓ 100 callersMethodparse

(String stmt)

src/main/java/io/mycat/server/parser/ServerParse.java:71

↓ 99 callersMethodwrite

(ByteBuffer buffer, FrontendConnection c,boolean writeSocketIfFull)

src/main/java/io/mycat/net/mysql/EOFPacket.java:66

↓ 98 callersMethodgetConnection

()

src/main/java/io/mycat/util/ZKUtils.java:52

↓ 97 callersMethodformat

格式化后返回的字符串 @param s 需要格式化的原始字符串，默认按左对齐。 @param fillLength 填充长度 @return String

src/main/java/io/mycat/util/FormatUtil.java:53

↓ 96 callersMethodequals

(Object other)

src/main/java/io/mycat/backend/mysql/xa/ParticipantLogEntry.java:51

↓ 96 callersMethodgetLimitSize

@return -1 if no limit

src/main/java/io/mycat/route/RouteResultset.java:314

↓ 95 callersMethodparse

(String stmt, int offset)

src/main/java/io/mycat/route/parser/ManagerParseShow.java:86

↓ 94 callersMethodcontainsKey

(Object key)

src/main/java/io/mycat/config/model/TableConfigMap.java:25

↓ 93 callersMethodgetData

获取堆数据 @return

src/main/java/io/mycat/sqlengine/mpp/tmp/HeapItf.java:36

↓ 91 callersMethodhasNext

()

src/main/java/io/mycat/util/SmallSet.java:102

↓ 91 callersMethodtoLowerCase

Returns the lower case of this string

src/main/java/io/mycat/memory/unsafe/types/UTF8String.java:353

↓ 90 callersMethodequals

递归地比较两个数组是否相同，支持多维数组。 <p> 如果比较的对象不是数组，则此方法的结果同<code>ObjectUtil.equals</code>。 </p> @param array1 数组1 @param array2 数组2 @return

src/main/java/io/mycat/util/ObjectUtil.java:102

↓ 86 callersMethodgetBytes

(short data)

src/main/java/io/mycat/util/ByteUtil.java:102

↓ 86 callersMethodkeySet

()

src/main/java/io/mycat/config/util/OrderRetainingMap.java:55

↓ 83 callersMethodcontains

(String[] list, String str)

src/main/java/io/mycat/route/parser/util/ArrayUtil.java:37

↓ 83 callersMethodwrite

(ByteBuffer bb, FrontendConnection c, boolean writeSocketIfFull)

src/main/java/io/mycat/net/mysql/RowDataPacket.java:89

↓ 83 callersMethodwriteErrMessage

(int errno, String msg)

src/main/java/io/mycat/net/FrontendConnection.java:229

↓ 80 callersMethodgetProperty

()

src/main/java/io/mycat/config/loader/zkprocess/entity/server/System.java:30

↓ 76 callersMethodentrySet

()

src/main/java/io/mycat/config/util/OrderRetainingMap.java:60

↓ 75 callersMethodgetHeader

(int fieldCount)

src/main/java/io/mycat/backend/mysql/PacketUtil.java:40

↓ 75 callersMethodgetLimitStart

()

src/main/java/io/mycat/route/RouteResultset.java:212

↓ 75 callersMethodtest

()

src/test/java/io/mycat/route/DQLRouteTest.java:52

↓ 74 callersMethodgetSystem

()

src/main/java/io/mycat/config/MycatConfig.java:95

↓ 74 callersMethodreplace

(String text, String repl, String with)

src/main/java/io/mycat/util/StringUtil.java:407

↓ 72 callersMethodstart

()

src/main/java/io/mycat/net/SocketAcceptor.java:5

↓ 71 callersMethodtoString

()

src/main/java/io/mycat/route/parser/util/Pair.java:49

↓ 70 callersMethodgetTables

()

src/main/java/io/mycat/route/parser/druid/DruidShardingParseInfo.java:65

↓ 69 callersMethodadd

(T t )

src/main/java/io/mycat/backend/mysql/nio/handler/MiddlerResultHandler.java:18

↓ 69 callersMethodgetBytes

Returns the underlying bytes for this UnsafeRow.

src/main/java/io/mycat/memory/unsafe/row/UnsafeRow.java:379

↓ 69 callersMethodgetConfig

()

src/main/java/io/mycat/backend/datasource/PhysicalDatasource.java:666

↓ 69 callersMethodwriteErrMessage

(ServerConnection c, String msg)

src/main/java/io/mycat/server/handler/MigrateHandler.java:430

↓ 67 callersMethodgetBytes

()

src/test/java/io/mycat/backend/jdbc/mongodb/MongoEmbeddedObjectProcessorTest.java:159

↓ 67 callersMethodgetLeft

()

src/main/java/io/mycat/sqlengine/mpp/HavingCols.java:20

↓ 66 callersMethodposition

()

src/main/java/io/mycat/backend/mysql/MySQLMessage.java:54

↓ 65 callersMethoditerator

()

src/main/java/io/mycat/util/SmallSet.java:96

↓ 62 callersMethodequals

(Object object)

src/main/java/io/mycat/config/util/BeanConfig.java:114

↓ 62 callersMethodexecute

开启一个会话执行

src/main/java/io/mycat/server/Session.java:47

↓ 62 callersMethodgetName

获得属性的名称方法描述 @return @创建日期 2016年9月15日

src/main/java/io/mycat/config/loader/zkprocess/entity/Named.java:13

↓ 61 callersMethodgetDataNodes

()

src/main/java/io/mycat/config/model/TableConfig.java:247

↓ 61 callersMethodparseLong

can parse values like 200M ,200K,200M1(2000001) @param val @return

src/main/java/io/mycat/route/function/NumberParseUtil.java:58

↓ 60 callersMethodcall

()

src/main/java/io/mycat/route/util/RouterUtil.java:1971

↓ 60 callersMethodparse

(String stmt)

src/main/java/io/mycat/route/parser/ManagerParse.java:51

↓ 60 callersMethodwriteToBuffer

(byte[] src, ByteBuffer buffer)

src/main/java/io/mycat/net/AbstractConnection.java:495

↓ 58 callersMethodadd

添加目录或者数据节点 @param branch

src/main/java/io/mycat/config/loader/zkprocess/zookeeper/DiretoryInf.java:28

↓ 58 callersMethodremoveBackquote

移除`符号 @param str @return

src/main/java/io/mycat/util/StringUtil.java:553

↓ 58 callersMethodtoString

()

src/main/java/io/mycat/route/parser/druid/LoadDataStatement.java:9

↓ 57 callersMethodgetTime

(byte[] bytes)

src/main/java/io/mycat/util/ByteUtil.java:202

↓ 55 callersMethodgetId

()

src/main/java/io/mycat/backend/BackendConnection.java:66

↓ 54 callersMethodgetFrom

()

src/main/java/io/mycat/migrate/MigrateTask.java:95

↓ 54 callersMethodgetStatement

()

src/main/java/io/mycat/route/RouteResultset.java:290

↓ 53 callersMethodaccept

( File dir , String name )

src/main/java/io/mycat/backend/mysql/xa/VersionedFile.java:60

↓ 53 callersMethodallocate

Allocates a contiguous block of memory. Note that the allocated memory is not guaranteed to be zeroed out (call `zero()` on the result if this is nece

src/main/java/io/mycat/memory/unsafe/memory/MemoryAllocator.java:26

↓ 53 callersMethodindexOf

()

src/test/java/io/mycat/memory/unsafe/types/UTF8StringSuite.java:237

↓ 52 callersMethodparse

(String stmt, int offset)

src/main/java/io/mycat/server/parser/ServerParseSet.java:51

↓ 51 callersMethodappend

(T item)

src/test/java/io/mycat/queue/Queue.java:77

next →1–100 of 7,572, ranked by callers