1. SmartSql Best Practices
1.1. Regular operation
1.1.1. Installing SmartSql
Install-Package SmartSql
1.1.2. Install SmartSql.DIExtension
Install-Package SmartSql.DIExtension
1.1.3. Configuring SmartSqlConfig.xml
- Write library (Write) mandatory
- Read library (Read) optional Multi-node configuration
1.1.4. Install the corresponding ADO.NET driver
MySql
- Install mysql driver Mysql.Data
Install-Package Mysql.Data
<?xml version="1.0" encoding="utf-8" ?>
<SmartSqlMapConfig xmlns="http://SmartSql.net/schemas/SmartSqlMapConfig.xsd">
<Settings IsWatchConfigFile="false" />
<Database>
<DbProvider Name="MySqlClientFactory" ParameterPrefix="?" Type="MySql.Data.MySqlClient.MySqlClientFactory,MySql.Data"/>
<Write Name="WriteDB" ConnectionString="Data Source=.;database=SmartSqlDB;uid=SmartSql;pwd=Rocher2018;Charset=utf8;SslMode=none"/>
<Read Name="ReadDB-0" ConnectionString="Data Source=.;database=SmartSqlDB-Read1;uid=SmartSql;pwd=Rocher2018;Charset=utf8;SslMode=none" Weight="80"/>
<Read Name="ReadDB-1" ConnectionString="Data Source=.;database=SmartSqlDB-Read2;uid=SmartSql;pwd=Rocher2018;Charset=utf8;SslMode=none" Weight="20"/>
</Database>
<SmartSqlMaps>
<SmartSqlMap Path="Maps" Type="Directory"></SmartSqlMap>
<SmartSqlMap Path="Maps/T_User.xml" Type="File"></SmartSqlMap>
</SmartSqlMaps>
</SmartSqlMapConfig>
MSSQL
<?xml version="1.0" encoding="utf-8" ?>
<SmartSqlMapConfig xmlns="http://SmartSql.net/schemas/SmartSqlMapConfig.xsd">
<Settings
IsWatchConfigFile="true"
/>
<Database>
<DbProvider Name="SqlClientFactory" ParameterPrefix="@" Type="System.Data.SqlClient.SqlClientFactory,System.Data.SqlClient"/>
<Write Name="WriteDB" ConnectionString="Data Source=.;database=SmartSqlDB;uid=SmartSql;pwd=Rocher2018"/>
<Read Name="ReadDB-1" ConnectionString="Data Source=.;database=SmartSqlDB-Read1;uid=SmartSql;pwd=Rocher2018"/>
<Read Name="ReadDB-2" ConnectionString="Data Source=.;database=SmartSqlDB-Read2;uid=SmartSql;pwd=Rocher2018"/>
</Database>
<SmartSqlMaps>
<SmartSqlMap Path="Maps" Type="Directory"></SmartSqlMap>
</SmartSqlMaps>
</SmartSqlMapConfig>
Postgresql
Install-Package Npgsql
<?xml version="1.0" encoding="utf-8" ?>
<SmartSqlMapConfig xmlns="http://SmartSql.net/schemas/SmartSqlMapConfig.xsd">
<Settings
IsWatchConfigFile="true"
/>
<Database>
<DbProvider Name="SqlClientFactory" ParameterPrefix="@" Type="Npgsql.NpgsqlFactory,Npgsql"/>
<Write Name="WriteDB" ConnectionString="Server=localhost;Port=5432;User Id=postgres;Password=Rocher2016; Database=SmartSqlDB;"/>
</Database>
<SmartSqlMaps>
<SmartSqlMap Path="Maps/" Type="Directory"></SmartSqlMap>
</SmartSqlMaps>
</SmartSqlMapConfig>
1.1.5. 注入依赖
services.AddSmartSqlRepositoryFromAssembly((options) =>
{
options.AssemblyString = "SmartSql.Starter.Repository";
});
1.1.6. Defining a warehousing interface
Public interface IUserRepository
{
IEnumerable<User> Query(object reqParams);
Long GetRecord(object reqParams);
User Get(object reqParams);
Long Insert(User entity);
Int Update(User entity);
Int Delete(User entity);
}
1.1.7. Enjoy yourself
using SmartSql.Abstractions;
using SmartSql.Starter.API.Message.Request.User;
using SmartSql.Starter.Repository;
using System;
namespace SmartSql.Starter.Service
{
public class UserService
{
private readonly ITransaction _transaction;
private readonly IUserRepository _userRepository;
public UserService(
ITransaction transaction
, IUserRepository userRepository)
{
_transaction = transaction;
_userRepository = userRepository;
}
public long Add(AddRequest request)
{
bool isExist = _userRepository.IsExist(new { EqUserName = request.UserName });
if (isExist)
{
throw new ArgumentException($"{nameof(request.UserName)} has already existed!");
}
return _userRepository.Insert(new Entitiy.User
{
UserName = request.UserName,
Pwd = request.Pwd,
Status = Entitiy.UserStatus.Ok,
CreationTime = DateTime.Now,
});
}
public int AddExtendData(AddExtendDataRequest request)
{
return _userRepository.InsertExtendData(new Entitiy.UserExtendData
{
UserId = request.UserId,
Info = request.Info
});
}
public int UpdateExtendData(UpdateExtendDataRequest request)
{
return _userRepository.UpdateExtendData(new Entitiy.UserExtendData
{
UserId = request.UserId,
Info = request.Info
});
}
public void UseTransaction()
{
try
{
_transaction.BeginTransaction();
_transaction.CommitTransaction();
}
catch (Exception ex)
{
_transaction.RollbackTransaction();
throw ex;
}
}
}
}