lsm/mdbtools
1
0
Fork 0
mirror of https://github.com/mdbtools/mdbtools.git synced 2025-11-26 10:29:27 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Add fflush after each newline (Pedro Gutierrez)

Browse Source
This commit is contained in:
whydoubt
2005-12-17 09:55:38 +00:00
parent 278b6e284c
commit 2b2e300513
2 changed files with 13 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
ChangeLog
View File

@@ -1,3 +1,6 @@
Sat Dec 17 03:49:30 CST 2005 Jeff Smith <whydoubt@yahoo.com>
* src/util/mdb-sql.c: Add fflush after each newline (Pedro Gutierrez)
Wed Nov 9 07:23:01 CST 2005 Jeff Smith <whydoubt@yahoo.com> Wed Nov 9 07:23:01 CST 2005 Jeff Smith <whydoubt@yahoo.com>
* src/util/mdb-array.c: * src/util/mdb-array.c:
* src/util/mdb-header.c: * src/util/mdb-header.c:

10
src/util/mdb-sql.c
View File

@@ -258,6 +258,7 @@ void print_rows_retrieved(FILE *out, unsigned long row_count)
fprintf(out, "1 Row retrieved\n"); fprintf(out, "1 Row retrieved\n");
else else
fprintf(out, "%lu Rows retrieved\n", row_count); fprintf(out, "%lu Rows retrieved\n", row_count);
fflush(out);
} }
void void
dump_results(FILE *out, MdbSQL *sql, char *delimiter) dump_results(FILE *out, MdbSQL *sql, char *delimiter)
@@ -275,6 +276,7 @@ dump_results(FILE *out, MdbSQL *sql, char *delimiter)
sqlcol = g_ptr_array_index(sql->columns,sql->num_columns-1); sqlcol = g_ptr_array_index(sql->columns,sql->num_columns-1);
fprintf(out, "%s", sqlcol->name); fprintf(out, "%s", sqlcol->name);
fprintf(out,"\n"); fprintf(out,"\n");
fflush(out);
} }
while(mdb_fetch_row(sql->cur_table)) { while(mdb_fetch_row(sql->cur_table)) {
row_count++; row_count++;
@@ -286,6 +288,7 @@ dump_results(FILE *out, MdbSQL *sql, char *delimiter)
sqlcol = g_ptr_array_index(sql->columns,sql->num_columns-1); sqlcol = g_ptr_array_index(sql->columns,sql->num_columns-1);
fprintf(out, "%s", sql->bound_values[sql->num_columns-1]); fprintf(out, "%s", sql->bound_values[sql->num_columns-1]);
fprintf(out,"\n"); fprintf(out,"\n");
fflush(out);
} }
if (footers) { if (footers) {
print_rows_retrieved(out, row_count); print_rows_retrieved(out, row_count);
@@ -310,11 +313,13 @@ dump_results_pp(FILE *out, MdbSQL *sql)
print_break(out, sqlcol->disp_size, !j); print_break(out, sqlcol->disp_size, !j);
} }
fprintf(out,"\n"); fprintf(out,"\n");
fflush(out);
for (j=0;j<sql->num_columns;j++) { for (j=0;j<sql->num_columns;j++) {
sqlcol = g_ptr_array_index(sql->columns,j); sqlcol = g_ptr_array_index(sql->columns,j);
print_value(out, sqlcol->name,sqlcol->disp_size,!j); print_value(out, sqlcol->name,sqlcol->disp_size,!j);
} }
fprintf(out,"\n"); fprintf(out,"\n");
fflush(out);
} }
for (j=0;j<sql->num_columns;j++) { for (j=0;j<sql->num_columns;j++) {
@@ -322,6 +327,7 @@ dump_results_pp(FILE *out, MdbSQL *sql)
print_break(out, sqlcol->disp_size, !j); print_break(out, sqlcol->disp_size, !j);
} }
fprintf(out,"\n"); fprintf(out,"\n");
fflush(out);
/* print each row */ /* print each row */
while(mdb_fetch_row(sql->cur_table)) { while(mdb_fetch_row(sql->cur_table)) {
@@ -331,6 +337,7 @@ dump_results_pp(FILE *out, MdbSQL *sql)
print_value(out, sql->bound_values[j],sqlcol->disp_size,!j); print_value(out, sql->bound_values[j],sqlcol->disp_size,!j);
} }
fprintf(out,"\n"); fprintf(out,"\n");
fflush(out);
} }
/* footer */ /* footer */
@@ -339,6 +346,7 @@ dump_results_pp(FILE *out, MdbSQL *sql)
print_break(out, sqlcol->disp_size, !j); print_break(out, sqlcol->disp_size, !j);
} }
fprintf(out,"\n"); fprintf(out,"\n");
fflush(out);
if (footers) { if (footers) {
print_rows_retrieved(out, row_count); print_rows_retrieved(out, row_count);
} }
@@ -374,9 +382,11 @@ char *delimiter = NULL;
g_free(histpath); g_free(histpath);
} }
#endif #endif
/* If input is coming from a pipe */
if (!isatty(fileno(stdin))) { if (!isatty(fileno(stdin))) {
in = stdin; in = stdin;
} }
while ((opt=getopt(argc, argv, "HFpd:i:o:"))!=-1) { while ((opt=getopt(argc, argv, "HFpd:i:o:"))!=-1) {
switch (opt) { switch (opt) {
case 'd': case 'd':