test for comment

JumpMind · Dec 7, 2007 · 685c2eb · 685c2eb
1 parent fa0f233
commit 685c2eb
Showing 1 changed file with 19 additions and 17 deletions.
diff --git a/symmetric/src/main/java/org/jumpmind/symmetric/db/SqlScript.java b/symmetric/src/main/java/org/jumpmind/symmetric/db/SqlScript.java
@@ -89,25 +89,27 @@ private void executeScript(Statement st) throws SQLException {
             String line;
             StringBuilder sql = new StringBuilder();
 
-            while ((line = reader.readLine()) != null && ! isComment(line)) {
-                if (checkStatementEnds(line)) {
-                    sql.append(line.substring(0, line.indexOf(delimiter)));
-                    if (logger.isDebugEnabled()) {
-                        logger.debug("query->" + sql);
-                    }
-                    try {
-                        st.execute(sql.toString());
-                    } catch (SQLException e) {
-                        if (failOnError) {
-                            logger.error(sql.toString() + " failed to execute.", e);
-                            throw e;
-                        } else {
-                            logger.warn(e.getMessage() + ": " + sql.toString());
+            while ((line = reader.readLine()) != null) {
+                if (! isComment(line)) {
+                    if (checkStatementEnds(line)) {
+                        sql.append(line.substring(0, line.indexOf(delimiter)));
+                        if (logger.isDebugEnabled()) {
+                            logger.debug("query->" + sql);
+                        }
+                        try {
+                            st.execute(sql.toString());
+                        } catch (SQLException e) {
+                            if (failOnError) {
+                                logger.error(sql.toString() + " failed to execute.", e);
+                                throw e;
+                            } else {
+                                logger.warn(e.getMessage() + ": " + sql.toString());
+                            }
                         }
+                        sql.setLength(0);
+                    } else {
+                        sql.append(line);
                     }
-                    sql.setLength(0);
-                } else {
-                    sql.append(line);
                 }
             }
         } catch (IOException e) {