code: function makeStream(conn) {
      return function stream(sql, options = { highWaterMark: 5 }) {
          return conn.query(sql).stream(options);
      };
  }
docs: ****************************************
  生成数据库查询流
  ****************************************