Skip to content

Commit

Permalink
代码整理
Browse files Browse the repository at this point in the history
  • Loading branch information
@codefollower
codefollower committed Oct 12, 2015
1 parent 6e67e63 commit 99588d6
Show file tree
Hide file tree
Showing 11 changed files with 37 additions and 51 deletions.
3 changes: 0 additions & 3 deletions lealone-db/src/main/java/org/lealone/db/index/StandardIndex.java
View file
Expand Up @@ -10,9 +10,6 @@
import org.lealone.db.Session; import org.lealone.db.Session;
import org.lealone.db.result.Row; import org.lealone.db.result.Row;


/**
* An index that stores the data in an MVStore.
*/
public interface StandardIndex extends Index { public interface StandardIndex extends Index {


/** /**
Expand Down
13 changes: 4 additions & 9 deletions lealone-db/src/main/java/org/lealone/db/index/StandardPrimaryIndex.java
View file
Expand Up @@ -28,13 +28,9 @@
import org.lealone.db.table.StandardTable; import org.lealone.db.table.StandardTable;
import org.lealone.db.table.TableFilter; import org.lealone.db.table.TableFilter;
import org.lealone.storage.Storage; import org.lealone.storage.Storage;
import org.lealone.storage.StorageEngine;
import org.lealone.transaction.TransactionEngine; import org.lealone.transaction.TransactionEngine;
import org.lealone.transaction.TransactionMap; import org.lealone.transaction.TransactionMap;


/**
* A primary index stored in a storage.
*/
public class StandardPrimaryIndex extends IndexBase { public class StandardPrimaryIndex extends IndexBase {


/** /**
Expand All @@ -58,10 +54,9 @@ public class StandardPrimaryIndex extends IndexBase {
private long lastKey; private long lastKey;
private int mainIndexColumn = -1; private int mainIndexColumn = -1;


public StandardPrimaryIndex(StorageEngine storageEngine, Session session, StandardTable table, int id, public StandardPrimaryIndex(Session session, StandardTable table) {
IndexColumn[] columns, IndexType indexType) { IndexColumn[] columns = IndexColumn.wrap(table.getColumns());

initIndexBase(table, table.getId(), table.getName() + "_DATA", columns, IndexType.createScan(true));
initIndexBase(table, id, table.getName() + "_DATA", columns, indexType);


this.table = table; this.table = table;
int[] sortTypes = new int[columns.length]; int[] sortTypes = new int[columns.length];
Expand All @@ -72,7 +67,7 @@ public StandardPrimaryIndex(StorageEngine storageEngine, Session session, Standa
ValueDataType valueType = new ValueDataType(database.getCompareMode(), database, sortTypes); ValueDataType valueType = new ValueDataType(database.getCompareMode(), database, sortTypes);
mapName = "table." + table.getName() + "." + getId(); mapName = "table." + table.getName() + "." + getId();


Storage storage = database.getStorage(storageEngine); Storage storage = database.getStorage(table.getStorageEngine());
TransactionEngine transactionEngine = database.getTransactionEngine(); TransactionEngine transactionEngine = database.getTransactionEngine();
dataMap = transactionEngine.beginTransaction(false).openMap(mapName, table.getMapType(), keyType, valueType, dataMap = transactionEngine.beginTransaction(false).openMap(mapName, table.getMapType(), keyType, valueType,
storage); storage);
Expand Down
14 changes: 4 additions & 10 deletions lealone-db/src/main/java/org/lealone/db/index/StandardSecondaryIndex.java
View file
Expand Up @@ -29,24 +29,18 @@
import org.lealone.db.table.StandardTable; import org.lealone.db.table.StandardTable;
import org.lealone.db.table.TableFilter; import org.lealone.db.table.TableFilter;
import org.lealone.storage.Storage; import org.lealone.storage.Storage;
import org.lealone.storage.StorageEngine;
import org.lealone.transaction.TransactionEngine; import org.lealone.transaction.TransactionEngine;
import org.lealone.transaction.TransactionMap; import org.lealone.transaction.TransactionMap;


/**
* A secondary index stored in a storage.
*/
public class StandardSecondaryIndex extends IndexBase implements StandardIndex { public class StandardSecondaryIndex extends IndexBase implements StandardIndex {


private final StandardTable table; private final StandardTable table;
private final int keyColumns; private final int keyColumns;
private final String mapName; private final String mapName;
private final TransactionMap<Value, Value> dataMap; private final TransactionMap<Value, Value> dataMap;
private final StorageEngine storageEngine;


public StandardSecondaryIndex(StorageEngine storageEngine, Session session, StandardTable table, int id, public StandardSecondaryIndex(Session session, StandardTable table, int id, String indexName,
String indexName, IndexColumn[] columns, IndexType indexType) { IndexColumn[] columns, IndexType indexType) {
this.storageEngine = storageEngine;
Database db = session.getDatabase(); Database db = session.getDatabase();
this.table = table; this.table = table;
initIndexBase(table, id, indexName, columns, indexType); initIndexBase(table, id, indexName, columns, indexType);
Expand All @@ -65,7 +59,7 @@ public StandardSecondaryIndex(StorageEngine storageEngine, Session session, Stan
ValueDataType keyType = new ValueDataType(db.getCompareMode(), db, sortTypes); ValueDataType keyType = new ValueDataType(db.getCompareMode(), db, sortTypes);
ValueDataType valueType = new ValueDataType(null, null, null); ValueDataType valueType = new ValueDataType(null, null, null);


Storage storage = database.getStorage(storageEngine); Storage storage = database.getStorage(table.getStorageEngine());
TransactionEngine transactionEngine = database.getTransactionEngine(); TransactionEngine transactionEngine = database.getTransactionEngine();
dataMap = transactionEngine.beginTransaction(false).openMap(mapName, table.getMapType(), keyType, valueType, dataMap = transactionEngine.beginTransaction(false).openMap(mapName, table.getMapType(), keyType, valueType,
storage); storage);
Expand Down Expand Up @@ -168,7 +162,7 @@ private TransactionMap<Value, Value> openMap(Session session, String mapName) {
ValueDataType keyType = new ValueDataType(database.getCompareMode(), database, sortTypes); ValueDataType keyType = new ValueDataType(database.getCompareMode(), database, sortTypes);
ValueDataType valueType = new ValueDataType(null, null, null); ValueDataType valueType = new ValueDataType(null, null, null);


Storage storage = database.getStorage(storageEngine); Storage storage = database.getStorage(table.getStorageEngine());
TransactionEngine transactionEngine = database.getTransactionEngine(); TransactionEngine transactionEngine = database.getTransactionEngine();
TransactionMap<Value, Value> map = transactionEngine.beginTransaction(false).openMap(mapName, TransactionMap<Value, Value> map = transactionEngine.beginTransaction(false).openMap(mapName,
table.getMapType(), keyType, valueType, storage); table.getMapType(), keyType, valueType, storage);
Expand Down
14 changes: 7 additions & 7 deletions lealone-db/src/main/java/org/lealone/db/schema/Schema.java
View file
Expand Up @@ -606,18 +606,18 @@ public Table createTable(CreateTableData data) {
data.schema = this; data.schema = this;


// 先看看是否在连接参数中指定了 // 先看看是否在连接参数中指定了
if (data.storageEngine == null && data.session.getConnectionInfo() != null) { if (data.storageEngineName == null && data.session.getConnectionInfo() != null) {
data.storageEngine = data.session.getConnectionInfo().getDbSettings().defaultStorageEngine; data.storageEngineName = data.session.getConnectionInfo().getDbSettings().defaultStorageEngine;
} }
// 再用默认的数据库参数 // 再用默认的数据库参数
if (data.storageEngine == null) { if (data.storageEngineName == null) {
data.storageEngine = database.getStorageEngineName(); data.storageEngineName = database.getStorageEngineName();
} }
if (data.storageEngine != null) { if (data.storageEngineName != null) {
StorageEngine engine = StorageEngineManager.getInstance().getEngine(data.storageEngine); StorageEngine engine = StorageEngineManager.getInstance().getEngine(data.storageEngineName);
if (engine == null) { if (engine == null) {
try { try {
engine = (StorageEngine) Utils.loadUserClass(data.storageEngine).newInstance(); engine = (StorageEngine) Utils.loadUserClass(data.storageEngineName).newInstance();
StorageEngineManager.getInstance().registerEngine(engine); StorageEngineManager.getInstance().registerEngine(engine);
} catch (Exception e) { } catch (Exception e) {
throw DbException.convert(e); throw DbException.convert(e);
Expand Down
2 changes: 1 addition & 1 deletion lealone-db/src/main/java/org/lealone/db/table/CreateTableData.java
View file
Expand Up @@ -71,7 +71,7 @@ public class CreateTableData {
/** /**
* The storage engine to use for creating the table. * The storage engine to use for creating the table.
*/ */
public String storageEngine; public String storageEngineName;


/** /**
* The storage engine parameters to use for creating the table. * The storage engine parameters to use for creating the table.
Expand Down
18 changes: 9 additions & 9 deletions lealone-db/src/main/java/org/lealone/db/table/StandardTable.java
View file
Expand Up @@ -43,9 +43,6 @@
import org.lealone.storage.StorageEngine; import org.lealone.storage.StorageEngine;
import org.lealone.transaction.Transaction; import org.lealone.transaction.Transaction;


/**
* A standard table stored in a storage.
*/
public class StandardTable extends TableBase { public class StandardTable extends TableBase {


private final StandardPrimaryIndex primaryIndex; private final StandardPrimaryIndex primaryIndex;
Expand Down Expand Up @@ -98,8 +95,7 @@ public StandardTable(CreateTableData data, StorageEngine storageEngine) {
} else } else
mapType = null; mapType = null;


primaryIndex = new StandardPrimaryIndex(storageEngine, data.session, this, getId(), primaryIndex = new StandardPrimaryIndex(data.session, this);
IndexColumn.wrap(getColumns()), IndexType.createScan(true));
indexes.add(primaryIndex); indexes.add(primaryIndex);
} }


Expand All @@ -111,6 +107,10 @@ public String getMapType() {
return mapType; return mapType;
} }


public StorageEngine getStorageEngine() {
return storageEngine;
}

@Override @Override
public boolean lock(Session session, boolean exclusive, boolean forceLockEvenInMvcc) { public boolean lock(Session session, boolean exclusive, boolean forceLockEvenInMvcc) {
int lockMode = database.getLockMode(); int lockMode = database.getLockMode();
Expand Down Expand Up @@ -420,7 +420,7 @@ public Index addIndex(Session session, String indexName, int indexId, IndexColum
Index index; Index index;
int mainIndexColumn = getMainIndexColumn(indexType, cols); int mainIndexColumn = getMainIndexColumn(indexType, cols);
if (indexType.isDelegate()) { if (indexType.isDelegate()) {
index = createMVDelegateIndex(indexId, indexName, indexType, mainIndexColumn); index = createDelegateIndex(indexId, indexName, indexType, mainIndexColumn);
} else { } else {
if (database.isStarting()) { if (database.isStarting()) {
if (database.getStorage(storageEngine).hasMap("index." + indexId)) { if (database.getStorage(storageEngine).hasMap("index." + indexId)) {
Expand All @@ -430,7 +430,7 @@ public Index addIndex(Session session, String indexName, int indexId, IndexColum
mainIndexColumn = -1; mainIndexColumn = -1;
} }
if (mainIndexColumn != -1) { if (mainIndexColumn != -1) {
index = createMVDelegateIndex(indexId, indexName, indexType, mainIndexColumn); index = createDelegateIndex(indexId, indexName, indexType, mainIndexColumn);
} else if (isGlobalUniqueIndex(session, indexType)) { } else if (isGlobalUniqueIndex(session, indexType)) {
index = new GlobalUniqueIndex(session, this, indexId, indexName, cols, indexType); index = new GlobalUniqueIndex(session, this, indexId, indexName, cols, indexType);
containsGlobalUniqueIndex = true; containsGlobalUniqueIndex = true;
Expand All @@ -441,7 +441,7 @@ public Index addIndex(Session session, String indexName, int indexId, IndexColum
index = new NonUniqueHashIndex(this, indexId, indexName, cols, indexType); index = new NonUniqueHashIndex(this, indexId, indexName, cols, indexType);
} }
} else { } else {
index = new StandardSecondaryIndex(storageEngine, session, this, indexId, indexName, cols, indexType); index = new StandardSecondaryIndex(session, this, indexId, indexName, cols, indexType);
} }
if (index instanceof StandardIndex && index.needRebuild()) { if (index instanceof StandardIndex && index.needRebuild()) {
rebuildIndex(session, (StandardIndex) index, indexName); rebuildIndex(session, (StandardIndex) index, indexName);
Expand All @@ -467,7 +467,7 @@ private boolean isGlobalUniqueIndex(Session session, IndexType indexType) {
// !session.isLocal(); // !session.isLocal();
} }


private StandardDelegateIndex createMVDelegateIndex(int indexId, String indexName, IndexType indexType, private StandardDelegateIndex createDelegateIndex(int indexId, String indexName, IndexType indexType,
int mainIndexColumn) { int mainIndexColumn) {
primaryIndex.setMainIndexColumn(mainIndexColumn); primaryIndex.setMainIndexColumn(mainIndexColumn);
return new StandardDelegateIndex(this, indexId, indexName, primaryIndex, indexType); return new StandardDelegateIndex(this, indexId, indexName, primaryIndex, indexType);
Expand Down
6 changes: 3 additions & 3 deletions lealone-db/src/main/java/org/lealone/db/table/Table.java
View file
Expand Up @@ -100,7 +100,7 @@ public abstract class Table extends SchemaObjectBase {
/** /**
* The table engine used (null for regular tables). * The table engine used (null for regular tables).
*/ */
protected String storageEngine; protected String storageEngineName;


private final HashMap<String, Column> columnMap; private final HashMap<String, Column> columnMap;
private final boolean persistIndexes; private final boolean persistIndexes;
Expand Down Expand Up @@ -1162,8 +1162,8 @@ public Column getColumn(String columnFamilyName, String columnName, boolean isIn
return getColumn(columnName); return getColumn(columnName);
} }


public String getStorageEngine() { public String getStorageEngineName() {
return storageEngine; return storageEngineName;
} }


public void addColumn(Column column) { public void addColumn(Column column) {
Expand Down
8 changes: 4 additions & 4 deletions lealone-db/src/main/java/org/lealone/db/table/TableBase.java
View file
Expand Up @@ -42,7 +42,7 @@ public abstract class TableBase extends Table {


public TableBase(CreateTableData data) { public TableBase(CreateTableData data) {
super(data.schema, data.id, data.tableName, data.persistIndexes, data.persistData); super(data.schema, data.id, data.tableName, data.persistIndexes, data.persistData);
this.storageEngine = data.storageEngine; this.storageEngineName = data.storageEngineName;
this.globalTemporary = data.globalTemporary; this.globalTemporary = data.globalTemporary;


setTemporary(data.temporary); setTemporary(data.temporary);
Expand Down Expand Up @@ -110,11 +110,11 @@ public String getCreateSQL() {
buff.append(column.getCreateSQL()); buff.append(column.getCreateSQL());
} }
buff.append("\n)"); buff.append("\n)");
if (storageEngine != null) { if (storageEngineName != null) {
String d = getDatabase().getSettings().defaultStorageEngine; String d = getDatabase().getSettings().defaultStorageEngine;
if (d == null || !storageEngine.endsWith(d)) { if (d == null || !storageEngineName.endsWith(d)) {
buff.append("\nENGINE \""); buff.append("\nENGINE \"");
buff.append(storageEngine); buff.append(storageEngineName);
buff.append('\"'); buff.append('\"');
} }
} }
Expand Down
4 changes: 2 additions & 2 deletions lealone-sql/src/main/java/org/lealone/sql/Parser.java
View file
Expand Up @@ -5520,9 +5520,9 @@ private CreateTable parseCreateTable(boolean temp, boolean globalTemp, boolean p
// throw DbException.get(ErrorCode.FEATURE_NOT_SUPPORTED_1, storageEngine); // throw DbException.get(ErrorCode.FEATURE_NOT_SUPPORTED_1, storageEngine);
// } // }
// } // }
command.setStorageEngine(readUniqueIdentifier()); command.setStorageEngineName(readUniqueIdentifier());
} else if (database.getSettings().defaultStorageEngine != null) { } else if (database.getSettings().defaultStorageEngine != null) {
command.setStorageEngine(database.getSettings().defaultStorageEngine); command.setStorageEngineName(database.getSettings().defaultStorageEngine);
} }
if (readIf("WITH")) { if (readIf("WITH")) {
read("("); read("(");
Expand Down
2 changes: 1 addition & 1 deletion lealone-sql/src/main/java/org/lealone/sql/ddl/AlterTableAlterColumn.java
View file
Expand Up @@ -313,7 +313,7 @@ private Table cloneTableStructure(Column[] columns, Database db, String tempName
data.isHidden = table.isHidden(); data.isHidden = table.isHidden();
data.create = true; data.create = true;
data.session = session; data.session = session;
data.storageEngine = table.getStorageEngine(); data.storageEngineName = table.getStorageEngineName();
Table newTable = getSchema().createTable(data); Table newTable = getSchema().createTable(data);
newTable.setComment(table.getComment()); newTable.setComment(table.getComment());
StringBuilder buff = new StringBuilder(); StringBuilder buff = new StringBuilder();
Expand Down
4 changes: 2 additions & 2 deletions lealone-sql/src/main/java/org/lealone/sql/ddl/CreateTable.java
View file
Expand Up @@ -285,8 +285,8 @@ public void setSortedInsertMode(boolean sortedInsertMode) {
this.sortedInsertMode = sortedInsertMode; this.sortedInsertMode = sortedInsertMode;
} }


public void setStorageEngine(String storageEngine) { public void setStorageEngineName(String storageEngineName) {
data.storageEngine = storageEngine; data.storageEngineName = storageEngineName;
} }


public void setStorageEngineParams(Map<String, String> storageEngineParams) { public void setStorageEngineParams(Map<String, String> storageEngineParams) {
Expand Down

0 comments on commit 99588d6

Please sign in to comment.