@@ -1393,7 +1393,7 @@ t('Copy write as first works', async() => {
1393
1393
t ( 'Copy from file works' , async ( ) => {
1394
1394
await sql `create table test (x int, y int, z int)`
1395
1395
await new Promise ( r => fs
1396
- . createReadStream ( 'copy.csv' )
1396
+ . createReadStream ( path . join ( __dirname , 'copy.csv' ) )
1397
1397
. pipe ( sql `copy test from stdin` . writable ( ) )
1398
1398
. on ( 'finish' , r )
1399
1399
)
@@ -1421,7 +1421,7 @@ t('Copy from works in transaction', async() => {
1421
1421
1422
1422
t ( 'Copy from abort works' , async ( ) => {
1423
1423
const sql = postgres ( options )
1424
- const readable = fs . createReadStream ( 'copy.csv' )
1424
+ const readable = fs . createReadStream ( path . join ( __dirname , 'copy.csv' ) )
1425
1425
1426
1426
await sql `create table test (x int, y int, z int)`
1427
1427
await sql `TRUNCATE TABLE test`
@@ -1450,7 +1450,8 @@ t('Recreate prepared statements on transformAssignedExpr error', async() => {
1450
1450
await insert ( )
1451
1451
await sql `alter table test alter column name type int using name::integer`
1452
1452
return [
1453
- 1 , ( await insert ( ) ) [ 0 ] . name ,
1453
+ 1 ,
1454
+ ( await insert ( ) ) [ 0 ] . name ,
1454
1455
await sql `drop table test`
1455
1456
]
1456
1457
} )
@@ -1462,7 +1463,8 @@ t('Recreate prepared statements on RevalidateCachedQuery error', async() => {
1462
1463
await select ( )
1463
1464
await sql `alter table test alter column name type int using name::integer`
1464
1465
return [
1465
- 1 , ( await select ( ) ) [ 0 ] . name ,
1466
+ 1 ,
1467
+ ( await select ( ) ) [ 0 ] . name ,
1466
1468
await sql `drop table test`
1467
1469
]
1468
1470
} )
0 commit comments