逐行执行 @param reader 字符输入流
(Reader reader)
| 143 | * @param reader 字符输入流 |
| 144 | */ |
| 145 | private void executeLineByLine(Reader reader) { |
| 146 | StringBuilder command = new StringBuilder(); |
| 147 | try { |
| 148 | BufferedReader lineReader = new BufferedReader(reader); |
| 149 | String line; |
| 150 | while ((line = lineReader.readLine()) != null) { |
| 151 | command = handleLine(command, line); |
| 152 | } |
| 153 | commitConnection(); |
| 154 | checkForMissingLineTerminator(command); |
| 155 | } catch (Exception e) { |
| 156 | String message = "逐行执行错误: " + command + ". 原因: " + e; |
| 157 | printlnError(message); |
| 158 | if (logger.isErrorEnabled()) { |
| 159 | logger.error("逐行执行错误: " + command ,e); |
| 160 | } |
| 161 | throw new RuntimeException(message, e); |
| 162 | } |
| 163 | } |
| 164 | /** |
| 165 | * 关闭连接 |
| 166 | */ |
no test coverage detected