GVKun编程网logo

go mssql 查询语句到实体中 ,goland 简单连接 sqlserver,并查询数据到实体中

7

以上就是给各位分享gomssql查询语句到实体中,goland简单连接sqlserver,并查询数据到实体中,同时本文还将给你拓展C#相对路径access简单连接、Django连接mssql(SqlS

以上就是给各位分享go mssql 查询语句到实体中 ,goland 简单连接 sqlserver,并查询数据到实体中,同时本文还将给你拓展C# 相对路径 access 简单连接、Django 连接 mssql (SqlServer)、GoLand 设置终端单元不起作用 如何在 GoLand 中设置运行配置以在 cmd 或其他某种形式的终端中运行我的程序以允许我像这样设置单元格?、jdbc 简单连接 oracle 数据库等相关知识,如果能碰巧解决你现在面临的问题,别忘了关注本站,现在开始吧!

本文目录一览:

go mssql 查询语句到实体中 ,goland 简单连接 sqlserver,并查询数据到实体中

go mssql 查询语句到实体中 ,goland 简单连接 sqlserver,并查询数据到实体中

go mssql 查询语句到实体中 ,

goland 简单连接 sqlserver,并查询数据到实体中

需要引用包:github.com/denisenkom/go-mssqldb

我们使用 cmd 执行:

go get github.com/denisenkom/go-mssqldb

在这里插入图片描述

上代码(简单例子):学习记录

/*
* copyright(C),2019-2020, email: 952651117@qq.com
* Author:  dao
* Version: 1.0.0
* Date:    2021/6/10 8:40
* Description:
*
 */

package main

import (
	"database/sql"
	"fmt"
	_ "github.com/denisenkom/go-mssqldb"
	"log"
)

type man struct {
	Id         int
	Name       string
	IsGraduate bool
}

func main() {
	//编写连接字符串
	connString := "server=120.79.19.125;port1433;database=cuyan;user id=cuyan;password=123456"
	//建立数据库连接:conn
	conn, err := sql.Open("mssql", connString)
	if err != nil {
		log.Fatal("Open Connection Failed:", err.Error())
	}
	defer conn.Close()
	//编写查询语句
	stmt, err := conn.Prepare(`select Name from [Student]`)
	if err != nil {
		log.Fatal("Prepare Failed:", err.Error())
	}
	defer stmt.Close()

	//执行查询语句
	rows, err := stmt.Query()
	if err != nil {
		log.Fatal("Query Failed:", err.Error())
	}
	//将数据读取到实体中
	var rowsData []*man
	for rows.Next() {
		row := new(man)
		//其中一个字段的信息 , 如果要获取更多,就在后面增加:rows.Scan(&row.Name,&row.Id)
		rows.Scan(&row.Name)
		rowsData = append(rowsData, row)
	}
	for _, v := range rowsData {
		//循环输出读取的数据
		fmt.Println(v.Name)
	}
}

执行后如下图:

在这里插入图片描述

C# 相对路径 access 简单连接

C# 相对路径 access 简单连接

DBHelper.cs

/*
 * By :落落
 * URL: Www.MyLuoLuo.Com
 */
using System;
using System.Collections.Generic;
using System.Text;
using System.Data;
using System.Data.OleDb;

namespace DBHelp
{
    /// <summary>
    /// Access Help
    /// </summary>
    public class Access
    {
        #region 小功能
        /// <summary>
        /// 数据库访问
        /// </summary>
        OleDbConnection conn;
        string conString;
        public OleDbConnection con
        {
            get
            {
                if (conn == null)
                {
                    conn = new OleDbConnection(conString);
                }
                if (conn.State == ConnectionState.Closed)
                {
                    conn.Open();

                }
                return conn;
            }
        }


        /// <summary>
        /// 数据库连接字符串
        /// </summary>
        /// <param name="conString"></param>
        public Access(string conString)
        {
            try
            {
                conn = new OleDbConnection(conString);
                this.conString = conString;
                conn.Open();
            }
            catch (Exception)
            {
                throw;
            }
        }


        /// <summary>
        /// 数据库连接字符串
        /// </summary>
        /// <param name="conString"></param>
        public Access()
        {
            try
            {
                //Provider=Microsoft.Jet.OLEDB.4.0;Data Source=data.love
                this.conString = "Provider=Microsoft.ACE.OLEDB.12.0;Data Source="+System.Web.HttpContext.Current.Server.MapPath("test3_bak.accdb");
                conn = new OleDbConnection(this.conString);
                conn.Open();
            }
            catch (Exception)
            {
                throw;
            }
        }



        /// <summary>
        /// 填充
        /// </summary>
        /// <param name="com"></param>
        /// <param name="array"></param>
        void SetParametersArray(ref OleDbCommand com, ParametersArray array)
        {
            foreach (OleDbParameter item in array.GetArray())
            {
                com.Parameters.Add(item);
            }
        }
        #endregion
        #region 执行SQL语句并返回受影响的行数
        /// <summary>
        /// 执行SQL语句并返回受影响的行数
        /// </summary>
        /// <returns></returns>
        public int ExecuteNonQuery(string sql)
        {
            try
            {
                using (OleDbCommand com = new OleDbCommand(sql, con))
                {
                    return com.ExecuteNonQuery();
                }
            }
            catch (Exception)
            {
                throw;
            }
        }


        /// <summary>
        /// 执行SQL语句并返回受影响的行数
        /// </summary>
        public int ExecuteNonQuery(string sql, OleDbParameter par)
        {
            try
            {
                using (OleDbCommand com = new OleDbCommand(sql, con))
                {
                    com.Parameters.Add(par);
                    return com.ExecuteNonQuery();
                }
            }
            catch (Exception)
            {
                throw;
            }
        }

        /// <summary>
        /// 执行SQL语句并返回受影响的行数
        /// </summary>
        /// <param name="sql"></param>
        /// <param name="array"></param>
        /// <returns></returns>
        public int ExecuteNonQuery(string sql, ParametersArray array)
        {
            try
            {
                OleDbCommand com = new OleDbCommand(sql, con);
                SetParametersArray(ref com, array);
                return com.ExecuteNonQuery();
            }
            catch (Exception)
            {

                throw;
            }
        }
        #endregion
        #region ExecuteReader
        public OleDbDataReader ExecuteReader(string sql)
        {
            try
            {
                using (OleDbCommand com = new OleDbCommand(sql, con))
                {
                    OleDbDataReader reader = com.ExecuteReader();
                    return reader;
                }
            }
            catch (Exception)
            {

                throw;
            }
        }
        public OleDbDataReader ExecuteReader(string sql, OleDbParameter par)
        {
            try
            {
                using (OleDbCommand com = new OleDbCommand(sql, con))
                {
                    com.Parameters.Add(par);
                    OleDbDataReader reader = com.ExecuteReader();
                    return reader;
                }
            }
            catch (Exception)
            {

                throw;
            }
        }
        public OleDbDataReader ExecuteReader(string sql, ParametersArray array)
        {
            try
            {
                OleDbCommand com = new OleDbCommand(sql, con);
                SetParametersArray(ref com, array);
                OleDbDataReader reader = com.ExecuteReader();
                return reader;
            }
            catch (Exception)
            {

                throw;
            }
        }
        #endregion
        #region 读取查询结果中的第一行第一列
        /// <summary>
        /// 读取查询结果中的第一行第一列
        /// </summary>
        /// <param name="sql"></param>
        /// <returns></returns>
        public object ExecuteScalar(string sql)
        {
            try
            {
                using (OleDbCommand com = new OleDbCommand(sql, con))
                {
                    return com.ExecuteScalar();
                }
            }
            catch (Exception)
            {

                throw;
            }
        }

        /// <summary>
        /// 读取查询结果中的第一行第一列
        /// </summary>
        /// <param name="sql"></param>
        /// <returns></returns>
        public object ExecuteScalar(string sql, OleDbParameter par)
        {
            try
            {
                using (OleDbCommand com = new OleDbCommand(sql, con))
                {
                    com.Parameters.Add(par);
                    return com.ExecuteScalar();
                }
            }
            catch (Exception)
            {

                throw;
            }
        }

        /// <summary>
        /// 读取查询结果中的第一行第一列
        /// </summary>
        /// <param name="sql"></param>
        /// <returns></returns>
        public object ExecuteScalar(string sql, ParametersArray array)
        {
            try
            {
                OleDbCommand com = new OleDbCommand(sql, con);
                SetParametersArray(ref com, array);
                return com.ExecuteScalar();
            }
            catch (Exception)
            {

                throw;
            }
        }
        #endregion
        #region 执行Insert语句,并返回新添加的记录ID
        /// <summary>
        /// 执行Insert语句,并返回新添加的记录ID
        /// </summary>
        /// <returns></returns>
        public object ExecuteNonQueryAndGetIdentity(string sql)
        {
            try
            {
                using (OleDbCommand com = new OleDbCommand(sql, con))
                {
                    if (com.ExecuteNonQuery() >= 1)
                    {
                        com.CommandText = "select @@identity";
                        return com.ExecuteScalar();
                    }
                    else
                    {
                        throw new Exception("记录添加不成功!");
                    }
                }
            }
            catch (Exception)
            {
                throw;
            }
        }

        /// <summary>
        /// 执行Insert语句,并返回新添加的记录ID
        /// </summary>
        public object ExecuteNonQueryAndGetIdentity(string sql, OleDbParameter par)
        {
            try
            {
                using (OleDbCommand com = new OleDbCommand(sql, con))
                {
                    com.Parameters.Add(par);
                    if (com.ExecuteNonQuery() >= 1)
                    {
                        com.CommandText = "select @@identity";
                        return com.ExecuteScalar();
                    }
                    else
                    {
                        throw new Exception("记录添加不成功!");
                    }
                }
            }
            catch (Exception)
            {
                throw;
            }
        }

        /// <summary>
        /// 执行Insert语句,并返回新添加的记录ID
        /// </summary>
        /// <param name="sql"></param>
        /// <param name="array"></param>
        /// <returns></returns>
        public object ExecuteNonQueryAndGetIdentity(string sql, ParametersArray array)
        {
            try
            {
                OleDbCommand com = new OleDbCommand(sql, con);
                SetParametersArray(ref com, array);
                if (com.ExecuteNonQuery() >= 1)
                {
                    com.CommandText = "select @@identity";
                    return com.ExecuteScalar();
                }
                else
                {
                    throw new Exception("记录添加不成功!");
                }
            }
            catch (Exception)
            {

                throw;
            }
        }
        #endregion
        #region 返回DataSet
        /// <summary>
        /// 返回DataSet
        /// </summary>
        /// <param name="sql"></param>
        /// <returns></returns>
        public DataSet GetDataSet(string sql)
        {
            try
            {

                using (OleDbDataAdapter adpter = new OleDbDataAdapter(sql, con))
                {
                    DataSet ds = new DataSet();
                    adpter.Fill(ds);
                    return ds;
                }
            }
            catch (Exception)
            {
                throw;
            }

        }

        /// <summary>
        /// 返回DataSet
        /// </summary>
        /// <param name="sql"></param>
        /// <returns></returns>
        public DataSet GetDataSet(string sql, OleDbParameter par)
        {
            try
            {
                using (OleDbCommand com = new OleDbCommand(sql, con))
                {
                    com.Parameters.Add(par);
                    using (OleDbDataAdapter adpter = new OleDbDataAdapter(com))
                    {
                        DataSet ds = new DataSet();
                        adpter.Fill(ds);
                        return ds;
                    }
                }

            }
            catch (Exception)
            {
                throw;
            }
        }

        /// <summary>
        /// 返回DataSet
        /// </summary>
        /// <param name="sql"></param>
        /// <returns></returns>
        public DataSet GetDataSet(string sql, ParametersArray array)
        {
            try
            {
                OleDbCommand com = new OleDbCommand(sql, con);
                SetParametersArray(ref com, array);
                using (OleDbDataAdapter adpter = new OleDbDataAdapter(com))
                {
                    DataSet ds = new DataSet();
                    adpter.Fill(ds);
                    return ds;
                }
            }
            catch (Exception)
            {
                throw;
            }
        }
        #endregion

    }

    /// <summary>
    /// 一组Parameters对象
    /// </summary>
    public class ParametersArray
    {
        List<System.Data.OleDb.OleDbParameter> par = new List<System.Data.OleDb.OleDbParameter>();
        /// <summary>
        /// 添加新参数
        /// </summary>
        /// <param name="par"></param>
        public void Add(System.Data.OleDb.OleDbParameter par)
        {
            this.par.Add(par);
        }
        /// <summary>
        /// 获取全部
        /// </summary>
        /// <returns></returns>
        public List<System.Data.OleDb.OleDbParameter> GetArray()
        {
            return this.par;
        }
    }
}

类代码

using System;
using System.Collections.Generic;
using System.Linq;
using System.Web;
using System.Web.UI;
using System.Web.UI.WebControls;
using DBHelp;
using System.Data;

namespace WebApplication1
{
    public partial class WebForm1 : System.Web.UI.Page
    {
        protected void Page_Load(object sender, EventArgs e)
        {
            String sql = "select * from news_category";
            Access helper = new Access();
            DataTable dt = helper.GetDataSet(sql).Tables[0];
            Repeater1.DataSource = dt;
            Repeater1.DataBind();
        }
    }
}

页面代码

<asp:Repeater ID="Repeater1" runat="server">
            <ItemTemplate>
                <%#Eval("ID")%>&nbsp<%#Eval("category")%><br>
            </ItemTemplate>
        </asp:Repeater>

Django 连接 mssql (SqlServer)

Django 连接 mssql (SqlServer)

Django 连接 mssql (SqlServer)

 

方法一:

1、需要安装 pymssql

  pip install pymssql

2、使用方法:

复制代码
import pymssql

conn=pymssql.connect(host=''127.0.0.1'',user=''user'',password=''password'',database=''MyDB'')
cur=conn.cursor()
cur.execute(''select * from table1'')
#如果是插入、删除、更新语句切记要写提交命令con.commit() print (cur.fetchall()) cur.close() conn.close()
复制代码

 

方法二:

1、安装必要的组件:

  pip install django-sqlserver django-pytds pyodbc django-pyodbc pypiwin32  

2、修改 settings.py 的 DATABASES:

复制代码
DATABASES = {
    # ''default'': {
    #     ''ENGINE'': ''django.db.backends.sqlite3'',
    #     ''NAME'': os.path.join(BASE_DIR, ''db.sqlite3''),
    # }
    ''default'': {
        ''ENGINE'': ''sqlserver'',
        ''NAME'': ''MyDB'',
        ''HOST'': ''127.0.0.1'',
        ''PORT'': ''1433'',
        ''USER'': ''user'',
        ''PASSWORD'': ''password,
        ''OPTIONS'': {
            ''DRIVER'': ''SQL Server Native Client 10.0'',
        },
    }
}
复制代码

 

方法三:

1、需要安装 SQL Server Management Studio 或者 manually install Microsoft Data Access Components (MDAC) 程序。

2、安装 django-mssql 和 pywin32:

  pip install django-mssql

3、修改 settings.py 的 DATABASES:

复制代码
DATABASES = {
    # ''default'': {
    #     ''ENGINE'': ''django.db.backends.sqlite3'',
    #     ''NAME'': os.path.join(BASE_DIR, ''db.sqlite3''),
    # }

       ''default'': {
        ''NAME'': ''MyDB'',
        ''ENGINE'': ''sqlserver_ado'',
        ''HOST'': ''127.0.0.1'',
        ''USER'': ''user'',
        ''PASSWORD'': ''password'',
        ''OPTIONS'': {
            ''provider'': ''SQLOLEDB'', # Have also tried ''SQLCLI11'' and ''SQLOLEDB''
            ''extra_params'': ''DataTypeCompatibility=80''
        },
    }
}
复制代码

provider 为''SQLCLI10'' 时若有问题,可改成''SQLOLEDB'' ,反之亦然。

 

 方法四:

1、安装 django-pyodbc-azure 和 pyodbc

pip install django-pyodbc-azure pyodbc

2、修改 settings.py 的 DATABASES:

复制代码
DATABASES = {
    ''default'': {
         ''ENGINE'': ''sql_server.pyodbc'',
         ''NAME'': ''MyDB'',
         ''USER'': ''user'',
         ''PASSWORD'': ''password'',
         ''HOST'': ''127.0.0.1'',
         ''PORT'': '''',
          ''OPTIONS'': {
              ''driver'':''SQL Server Native Client 11.0'',
              ''MARS_Connection'': True,

         },
     },
}

# set this to False if you want to turn off pyodbc''s connection pooling
DATABASE_CONNECTION_POOLING = False
复制代码

 

 
 

GoLand 设置终端单元不起作用 如何在 GoLand 中设置运行配置以在 cmd 或其他某种形式的终端中运行我的程序以允许我像这样设置单元格?

GoLand 设置终端单元不起作用 如何在 GoLand 中设置运行配置以在 cmd 或其他某种形式的终端中运行我的程序以允许我像这样设置单元格?

如何解决GoLand 设置终端单元不起作用 如何在 GoLand 中设置运行配置以在 cmd 或其他某种形式的终端中运行我的程序以允许我像这样设置单元格?

我正在使用 tcell 库来显示终端单元图形。

在 GoLand 中编写这个项目时,我注意到使用正常的运行配置并在集成终端中运行程序,我没有看到单元格按预期设置,尽管 tcell 没有给出任何错误。>

程序:

package main

import (
    "time"
    "github.com/gdamore/tcell"  
)

func main() {
    screen,err := tcell.NewScreen()
    if err != nil {
        panic(err)
    }

    err = screen.Init()
    if err != nil {
        panic(err)
    }

    screen.SetCell(0,tcell.StyleDefault,''X'')
    screen.SetCell(1,1,''X'')
    screen.SetCell(10,10,''X'')
    screen.Show()

    time.Sleep(time.Second*5)
}

GoLand 输出:

GoLand terminal,doesn''t show Xs

该程序在通过 cmd 运行时按预期工作:

enter image description here

如何在 GoLand 中设置运行配置以在 cmd 或其他某种形式的终端中运行我的程序以允许我像这样设置单元格?

解决方法

  1. 打开Help | Find Action...
  2. 输入 Registry 并按 Enter。
  3. 在那里找到 go.run.processes.with.pty 并将其打开。

请记住,它可能会导致运行配置出现问题,例如绿色测试失败,反之亦然,永远无法完成调试会话,等等。如果您发现与控制台输出相关的奇怪 IDE 行为,请禁用注册表选项。

我不确定 Y 轴上的点是否在“运行”窗口中正确显示。

,

我猜 GoLands 终端是一个假终端,没有真正的光标寻址能力。如果是这种情况,可能没有好的解决方案。

我是 tcell 的作者,我使用 goland,但我承认我总是在真实终端而不是 IDE 提供的玩具终端中运行我的测试程序。无论我使用 goland、visual studio code 还是古老的 emacs,都是如此。

,

通过使用新的批处理运行配置,您可以运行批处理文件来构建程序,然后在新的 cmd 窗口中运行该程序。

在 GoLand 的运行配置中,将“工作目录”设置为主包目录。然后将脚本设置为新的批处理文件。

这是我的包 client 的批处理文件中的代码

go build
start cmd /C client.exe

运行此配置将构建包,然后在单元格正确显示的新外部 cmd 窗口中运行程序。

这个解决方案不是很好,因为 GoLand 运行配置系统的大部分优势都丢失了,包括调试、进程管理(停止/重启)和其他构建选项。

有人有更好的解决方案吗?

jdbc 简单连接 oracle 数据库

jdbc 简单连接 oracle 数据库

package com.shangsheng;

import java.sql.*;

public class UserOracle {
public static void main(String[] args) throws SQLException, ClassNotFoundException {
final String username="scott";
final String password="root";
final String url="jdbc:oracle:thin:@127.0.0.1:1521:orcl";
Class.forName("oracle.jdbc.driver.OracleDriver");
Connection connection = DriverManager.getConnection(url,username,password);
Statement statement = connection.createStatement();
// String sql="select * from usertest ";
// ResultSet resultSet = statement.executeQuery(sql);
// while (resultSet.next()){
// int anInt = resultSet.getInt(1);
// String string = resultSet.getString(2);
// System.out.println("id:"+anInt);
// System.out.println("name:"+string);
// }
      //create sequence usertest_key 创建序列
String sql="insert into USERTEST values(usertest_key.nextval,嘻嘻嘻'') ";
statement.execute(sql);
statement.close();
}
}

配置:
<dependency>
<groupId>com.hynnet</groupId>
<artifactId>oracle-driver-ojdbc</artifactId>
<version>12.1.0.2</version>
</dependency>

  

关于go mssql 查询语句到实体中 ,goland 简单连接 sqlserver,并查询数据到实体中的介绍已经告一段落,感谢您的耐心阅读,如果想了解更多关于C# 相对路径 access 简单连接、Django 连接 mssql (SqlServer)、GoLand 设置终端单元不起作用 如何在 GoLand 中设置运行配置以在 cmd 或其他某种形式的终端中运行我的程序以允许我像这样设置单元格?、jdbc 简单连接 oracle 数据库的相关信息,请在本站寻找。

本文标签: