diff -ur src.old/org/apache/lucene/store/jdbc/dialect/MySQLDialect.java src/org/apache/lucene/store/jdbc/dialect/MySQLDialect.java --- src.old/org/apache/lucene/store/jdbc/dialect/MySQLDialect.java 2006-02-16 02:17:00.000000000 +0200 +++ src/org/apache/lucene/store/jdbc/dialect/MySQLDialect.java 2006-12-09 18:20:20.179232000 +0200 @@ -27,14 +27,14 @@ * MySQL requires quoting the blob column with connector J 3.1 when using emulateLocators=true. */ public String openBlobSelectQuote() { - return "'"; + return "`"; } /** * MySQL requires quoting the blob column with connector J 3.1 when using emulateLocators=true. */ public String closeBlobSelectQuote() { - return "'"; + return "`"; } public char closeQuote() { @@ -95,6 +95,6 @@ } public String getBitType() { - return "bit"; + return "tinyint(1)"; } } diff -ur src.old/org/apache/lucene/store/jdbc/lock/PhantomReadLock.java src/org/apache/lucene/store/jdbc/lock/PhantomReadLock.java --- src.old/org/apache/lucene/store/jdbc/lock/PhantomReadLock.java 2006-02-16 02:17:00.000000000 +0200 +++ src/org/apache/lucene/store/jdbc/lock/PhantomReadLock.java 2006-12-09 10:03:34.323705600 +0200 @@ -18,6 +18,7 @@ import java.io.IOException; import java.sql.PreparedStatement; +import java.sql.Types; import org.apache.lucene.store.Lock; import org.apache.lucene.store.jdbc.JdbcDirectory; @@ -63,7 +64,7 @@ public void fillPrepareStatement(PreparedStatement ps) throws Exception { ps.setFetchSize(1); ps.setString(1, name); - ps.setBlob(2, null); + ps.setNull(2, Types.BLOB); ps.setLong(3, 0); ps.setBoolean(4, false); } diff -ur src.old/org/apache/lucene/store/jdbc/lock/SelectForUpdateLock.java src/org/apache/lucene/store/jdbc/lock/SelectForUpdateLock.java --- src.old/org/apache/lucene/store/jdbc/lock/SelectForUpdateLock.java 2006-02-16 02:17:00.000000000 +0200 +++ src/org/apache/lucene/store/jdbc/lock/SelectForUpdateLock.java 2006-12-17 01:22:17.019092800 +0200 @@ -19,6 +19,7 @@ import java.io.IOException; import java.sql.PreparedStatement; import java.sql.ResultSet; +import java.sql.Types; import org.apache.lucene.index.IndexWriter; import org.apache.lucene.store.Lock; @@ -60,7 +61,7 @@ public void fillPrepareStatement(PreparedStatement ps) throws Exception { ps.setFetchSize(1); ps.setString(1, IndexWriter.WRITE_LOCK_NAME); - ps.setBlob(2, null); + ps.setNull(2, Types.BLOB); ps.setLong(3, 0); ps.setBoolean(4, false); } @@ -70,7 +71,7 @@ public void fillPrepareStatement(PreparedStatement ps) throws Exception { ps.setFetchSize(1); ps.setString(1, IndexWriter.COMMIT_LOCK_NAME); - ps.setBlob(2, null); + ps.setNull(2, Types.BLOB); ps.setLong(3, 0); ps.setBoolean(4, false); }