fix close conn

Author: s0und0fs1lence

chdb-purego/binding.go

@@ -52,11 +52,11 @@ var (
 
 	// new API
 	chdbConnect                func(argc int, argv []*byte) *chdb_connection
-	chdbCloseConn              func(conn unsafe.Pointer)
+	chdbCloseConn              func(conn *chdb_connection)
 	chdbQuery                  func(conn unsafe.Pointer, query string, format string) *chdb_result
 	chdbStreamQuery            func(conn unsafe.Pointer, query string, format string) *chdb_result
 	chdbStreamFetchResult      func(conn unsafe.Pointer, result *chdb_result) *chdb_result
-	chdbStreamCancelQuery      func(conn unsafe.Pointer, result *chdb_result)
+	chdbStreamCancelQuery      func(conn *chdb_connection, result *chdb_result)
 	chdbDestroyQueryResult     func(result *chdb_result)
 	chdbResultBuffer           func(result *chdb_result) *byte
 	chdbResultLen              func(result *chdb_result) uint    //size_t

chdb-purego/chdb.go

@@ -114,7 +114,7 @@ func newChdbConn(conn *chdb_connection) ChdbConn {
 // Close implements ChdbConn.
 func (c *connection) Close() {
 	if c.conn != nil {
-		chdbCloseConn(c.conn.internal_data)
+		chdbCloseConn(c.conn)
 	}
 }
 

chdb-purego/streaming.go

@@ -37,7 +37,7 @@ func (c *streamingResult) Error() error {
 // Free implements ChdbStreamResult.
 func (c *streamingResult) Free() {
 	if c.curConn != nil && c.stream != nil {
-		//chdbStreamCancelQuery(c.curConn.internal_data, c.stream)
+		chdbStreamCancelQuery(c.curConn, c.stream)
 		chdbDestroyQueryResult(c.stream)
 	}