--- a/src/luan/modules/sql/Database.java	Mon Feb 18 05:11:50 2019 -0700
+++ b/src/luan/modules/sql/Database.java	Tue Feb 19 08:14:40 2019 -0700
@@ -11,6 +11,7 @@
 import java.util.Properties;
 import luan.lib.logging.Logger;
 import luan.lib.logging.LoggerFactory;
+import luan.Luan;
 import luan.LuanTable;
 import luan.LuanException;
 
@@ -20,6 +21,7 @@
 
 	public final Connection con;
 	private final Map<String,PreparedStatement> pstmts = new HashMap<String,PreparedStatement>();
+	private int fetchSize = 0;
 
 	public Database(Connection con) {
 		this.con = con;
@@ -35,6 +37,30 @@
 		Properties props = new Properties();
 		props.putAll(spec);
 		this.con = DriverManager.getConnection(url,props);
+		set(spec);
+	}
+
+	public void set(LuanTable options) throws LuanException, SQLException {
+		set(options.asMap());
+	}
+
+	private void set(Map<Object,Object> options) throws LuanException, SQLException {
+		Object obj;
+		obj = options.remove("auto_commit");
+		if( obj != null ) {
+			if( !(obj instanceof Boolean) )
+				throw new LuanException( "parameter 'auto_commit' must be a boolean" );
+			con.setAutoCommit((Boolean)obj);
+		}
+		obj = options.remove("fetch_size");
+		if( obj != null ) {
+			Integer n = Luan.asInteger(obj);
+			if( n == null )
+				throw new LuanException( "parameter 'fetch_size' must be an integer" );
+			fetchSize = n;
+		}
+		if( !options.isEmpty() )
+			throw new LuanException( "unrecognized parameters: "+options );
 	}
 
 	private static String getString(Map spec,String key) throws LuanException {
@@ -46,10 +72,16 @@
 		return (String)val;
 	}
 
+	private void fix(Statement stmt) throws SQLException {
+		if( fetchSize > 0 )
+			stmt.setFetchSize(fetchSize);
+	}
+
 	private PreparedStatement prepareStatement(String sql,Object[] args) throws SQLException {
 		PreparedStatement pstmt = pstmts.get(sql);
 		if( pstmt==null ) {
 			pstmt = con.prepareStatement(sql);
+			fix(pstmt);
 			pstmts.put(sql,pstmt);
 		}
 		for( int i=0; i<args.length; i++ ) {
@@ -61,6 +93,7 @@
 	public ResultSet query(String sql,Object... args) throws SQLException {
 		if( args.length == 0 ) {
 			Statement stmt = con.createStatement();
+			fix(stmt);
 			return stmt.executeQuery(sql);
 		} else {
 			PreparedStatement pstmt = prepareStatement(sql,args);
@@ -71,6 +104,7 @@
 	public int update(String sql,Object... args) throws SQLException {
 		if( args.length == 0 ) {
 			Statement stmt = con.createStatement();
+			fix(stmt);
 			int n = stmt.executeUpdate(sql);
 			stmt.close();
 			return n;