APIJSON/src/main/java/apijson/orm/SQLExecutor.java at main · APIJSON/APIJSON · GitHub

History

executable file

147 lines (119 loc) · 3.88 KB

Raw

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

145

146

147

This source code is licensed under the Apache License Version 2.0.*/

package apijson.orm;

import java.sql.Connection;

import java.sql.ResultSet;

import java.sql.ResultSetMetaData;

import java.sql.SQLException;

import java.sql.Savepoint;

import java.sql.Statement;

import java.util.List;

import java.util.Map;

import apijson.*;

/**executor for query(read) or update(write) MySQL database

* @author Lemon

public interface SQLExecutor<T, M extends Map<String, Object>, L extends List<Object>> {

Parser<T, M, L> getParser();

SQLExecutor<T, M, L> setParser(Parser<T, M, L> parser);

/**保存缓存

* @param sql

* @param list

* @param config

void putCache(String sql, List<M> list, SQLConfig<T, M, L> config);

/**获取缓存

* @param sql

* @param config

* @return

List<M> getCache(String sql, SQLConfig<T, M, L> config);

/**获取缓存

* @param sql

* @param position

* @param config

* @return

M getCacheItem(String sql, int position, SQLConfig<T, M, L> config);

/**移除缓存

* @param sql

* @param config

void removeCache(String sql, SQLConfig<T, M, L> config);

/**执行SQL

* @param config

* @param unknownType

* @return

* @throws Exception

M execute(@NotNull SQLConfig<T, M, L> config, boolean unknownType) throws Exception;

//executeQuery和executeUpdate这两个函数因为返回类型不同，所以不好合并

/**执行查询

* @param config

* @return

* @throws SQLException

default ResultSet executeQuery(@NotNull SQLConfig<T, M, L> config) throws Exception {

return executeQuery(config, null);

}

ResultSet executeQuery(@NotNull SQLConfig<T, M, L> config, String sql) throws Exception;

/**执行增、删、改

* @param config

* @return

* @throws SQLException

default int executeUpdate(@NotNull SQLConfig<T, M, L> config) throws Exception {

return executeUpdate(config, null);

}

int executeUpdate(@NotNull SQLConfig<T, M, L> config, String sql) throws Exception;

/**判断是否为JSON类型

* @param config

* @param rsmd

* @param position

* @param label

* @return

boolean isJSONType(@NotNull SQLConfig<T, M, L> config, ResultSetMetaData rsmd, int position, String label);

/**

* Convert a JDBC value to a JSON-serializable Java value. Database adapters can

* override this hook without replacing the complete result-set traversal.

default Object mapResultValue(@NotNull SQLConfig<T, M, L> config, Object value, int jdbcType

, String typeName, String label) throws Exception {

return value;

}

Connection getConnection(@NotNull SQLConfig<T, M, L> config) throws Exception;

default Statement getStatement(@NotNull SQLConfig<T, M, L> config) throws Exception {

return getStatement(config, null);

}

Statement getStatement(@NotNull SQLConfig<T, M, L> config, String sql) throws Exception;

int getTransactionIsolation();

void setTransactionIsolation(int transactionIsolation);

/**开始事务

* @throws SQLException

void begin(int transactionIsolation) throws SQLException;

/**回滚事务

* @throws SQLException

void rollback() throws SQLException;

/**提交事务

* @throws SQLException

void rollback(Savepoint savepoint) throws SQLException;

/**提交事务

* @throws SQLException

void commit() throws SQLException;

/**关闭连接，释放资源

void close();

ResultSet executeQuery(@NotNull Statement statement, String sql) throws Exception;

int executeUpdate(@NotNull Statement statement, String sql) throws Exception;

ResultSet execute(@NotNull Statement statement, String sql) throws Exception;

int getGeneratedSQLCount();

int getCachedSQLCount();

int getExecutedSQLCount();

long getExecutedSQLDuration();

long getSqlResultDuration();

}

APIJSON/src/main/java/apijson/orm/SQLExecutor.java at main · APIJSON/APIJSON · GitHub

Expand file tree

Breadcrumbs

SQLExecutor.java

Latest commit

History

Breadcrumbs

SQLExecutor.java

File metadata and controls